Uses of Class
io.vertx.rx.java.WriteStreamSubscriber

Packages that use WriteStreamSubscriber

Package	Description
io.vertx.rx.java
io.vertx.rxjava.amqp
io.vertx.rxjava.core.file
io.vertx.rxjava.core.http
io.vertx.rxjava.core.net
io.vertx.rxjava.ext.web.handler.sockjs
io.vertx.rxjava.kafka.client.producer

Uses of WriteStreamSubscriber in io.vertx.rx.java

Methods in io.vertx.rx.java that return WriteStreamSubscriber

Modifier and Type	Method and Description
abstract WriteStreamSubscriber<R>	WriteStreamSubscriber.onError(Action1<Throwable> handler) Sets the handler to invoke if the Observable that was subscribed to terminates with an error.
abstract WriteStreamSubscriber<R>	WriteStreamSubscriber.onWriteStreamEnd(Action0 handler) Sets the handler to invoke when the adapted WriteStream ends successfully.
abstract WriteStreamSubscriber<R>	WriteStreamSubscriber.onWriteStreamEndError(Action1<Throwable> handler) Sets the handler to invoke when the adapted WriteStream ends with an error.
abstract WriteStreamSubscriber<R>	WriteStreamSubscriber.onWriteStreamError(Action1<Throwable> handler) Sets the handler to invoke if the adapted WriteStream fails.
static <T> WriteStreamSubscriber<T>	RxHelper.toSubscriber(WriteStream<T> stream) Adapts a Vert.x WriteStream to an RxJava Subscriber.
static <R,T> WriteStreamSubscriber<R>	RxHelper.toSubscriber(WriteStream<T> stream, java.util.function.Function<R,T> mapping) Like RxHelper.toSubscriber(WriteStream), except the provided mapping function is applied to each Observable item.

Uses of WriteStreamSubscriber in io.vertx.rxjava.amqp

Methods in io.vertx.rxjava.amqp that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<AmqpMessage>	AmqpSender.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.core.file

Methods in io.vertx.rxjava.core.file that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Buffer>	AsyncFile.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.core.http

Methods in io.vertx.rxjava.core.http that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Buffer>	HttpServerResponse.toSubscriber()
WriteStreamSubscriber<Buffer>	ServerWebSocket.toSubscriber()
WriteStreamSubscriber<Buffer>	HttpClientRequest.toSubscriber()
WriteStreamSubscriber<Buffer>	WebSocket.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.core.net

Methods in io.vertx.rxjava.core.net that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Buffer>	NetSocket.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.ext.web.handler.sockjs

Methods in io.vertx.rxjava.ext.web.handler.sockjs that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Buffer>	SockJSSocket.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.kafka.client.producer

Methods in io.vertx.rxjava.kafka.client.producer that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<KafkaProducerRecord<K,V>>	KafkaProducer.toSubscriber()