Uses of Interface
io.vertx.reactivex.WriteStreamSubscriber

Packages that use WriteStreamSubscriber

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.grpc.client
io.vertx.reactivex.grpc.common
io.vertx.reactivex.grpc.server
io.vertx.reactivex.kafka.client.producer

Uses of WriteStreamSubscriber in io.vertx.reactivex

Methods in io.vertx.reactivex that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<R>	WriteStreamSubscriber.onError(Consumer<? super Throwable> handler) Sets the handler to invoke if the Flowable that was subscribed to terminates with an error.
WriteStreamSubscriber<R>	WriteStreamSubscriber.onWriteStreamEnd(Action handler) Sets the handler to invoke when the adapted WriteStream ends successfully.
WriteStreamSubscriber<R>	WriteStreamSubscriber.onWriteStreamEndError(Consumer<? super Throwable> handler) Sets the handler to invoke when the adapted WriteStream ends with an error.
WriteStreamSubscriber<R>	WriteStreamSubscriber.onWriteStreamError(Consumer<? super 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 Flowable item.

Uses of WriteStreamSubscriber in io.vertx.reactivex.amqp

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

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

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

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

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

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

Methods in io.vertx.reactivex.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.reactivex.core.net

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

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

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

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

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

Uses of WriteStreamSubscriber in io.vertx.reactivex.grpc.client

Methods in io.vertx.reactivex.grpc.client that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Req>	GrpcClientRequest.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.reactivex.grpc.common

Methods in io.vertx.reactivex.grpc.common that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<T>	GrpcWriteStream.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.reactivex.grpc.server

Methods in io.vertx.reactivex.grpc.server that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Resp>	GrpcServerResponse.toSubscriber()

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

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

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