Uses of Interface
io.vertx.reactivex.WriteStreamObserver

Packages that use WriteStreamObserver

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

Uses of WriteStreamObserver in io.vertx.reactivex

Methods in io.vertx.reactivex that return WriteStreamObserver

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

Uses of WriteStreamObserver in io.vertx.reactivex.amqp

Methods in io.vertx.reactivex.amqp that return WriteStreamObserver

Modifier and Type	Method and Description
WriteStreamObserver<AmqpMessage>	AmqpSender.toObserver()

Uses of WriteStreamObserver in io.vertx.reactivex.core.file

Methods in io.vertx.reactivex.core.file that return WriteStreamObserver

Modifier and Type	Method and Description
WriteStreamObserver<Buffer>	AsyncFile.toObserver()

Uses of WriteStreamObserver in io.vertx.reactivex.core.http

Methods in io.vertx.reactivex.core.http that return WriteStreamObserver

Modifier and Type	Method and Description
WriteStreamObserver<Buffer>	HttpServerResponse.toObserver()
WriteStreamObserver<Buffer>	ServerWebSocket.toObserver()
WriteStreamObserver<Buffer>	HttpClientRequest.toObserver()
WriteStreamObserver<Buffer>	WebSocket.toObserver()

Uses of WriteStreamObserver in io.vertx.reactivex.core.net

Methods in io.vertx.reactivex.core.net that return WriteStreamObserver

Modifier and Type	Method and Description
WriteStreamObserver<Buffer>	NetSocket.toObserver()

Uses of WriteStreamObserver in io.vertx.reactivex.ext.web.handler.sockjs

Methods in io.vertx.reactivex.ext.web.handler.sockjs that return WriteStreamObserver

Modifier and Type	Method and Description
WriteStreamObserver<Buffer>	SockJSSocket.toObserver()

Uses of WriteStreamObserver in io.vertx.reactivex.kafka.client.producer

Methods in io.vertx.reactivex.kafka.client.producer that return WriteStreamObserver

Modifier and Type	Method and Description
WriteStreamObserver<KafkaProducerRecord<K,V>>	KafkaProducer.toObserver()