Uses of Interface
io.vertx.reactivex.WriteStreamSubscriber
-
-
Uses of WriteStreamSubscriber in io.vertx.reactivex
Methods in io.vertx.reactivex that return WriteStreamSubscriber Modifier and Type Method Description WriteStreamSubscriber<R>WriteStreamSubscriber. onError(Consumer<? super Throwable> handler)Sets the handler to invoke if theFlowablethat was subscribed to terminates with an error.WriteStreamSubscriber<R>WriteStreamSubscriber. onWriteStreamEnd(Action handler)Sets the handler to invoke when the adaptedWriteStreamends successfully.WriteStreamSubscriber<R>WriteStreamSubscriber. onWriteStreamEndError(Consumer<? super Throwable> handler)Sets the handler to invoke when the adaptedWriteStreamends with an error.WriteStreamSubscriber<R>WriteStreamSubscriber. onWriteStreamError(Consumer<? super Throwable> handler)Sets the handler to invoke if the adaptedWriteStreamfails.static <T> WriteStreamSubscriber<T>RxHelper. toSubscriber(WriteStream<T> stream)Adapts a Vert.xWriteStreamto an RxJavaSubscriber.static <R,T>
WriteStreamSubscriber<R>RxHelper. toSubscriber(WriteStream<T> stream, java.util.function.Function<R,T> mapping)LikeRxHelper.toSubscriber(WriteStream), except the providedmappingfunction is applied to eachFlowableitem. -
Uses of WriteStreamSubscriber in io.vertx.reactivex.amqp
Methods in io.vertx.reactivex.amqp that return WriteStreamSubscriber Modifier and Type Method 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 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 Description WriteStreamSubscriber<Buffer>ClientWebSocket. toSubscriber()WriteStreamSubscriber<Buffer>HttpClientRequest. toSubscriber()WriteStreamSubscriber<Buffer>HttpServerResponse. toSubscriber()WriteStreamSubscriber<Buffer>ServerWebSocket. 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 Description WriteStreamSubscriber<Buffer>NetSocket. toSubscriber() -
Uses of WriteStreamSubscriber in io.vertx.reactivex.core.streams
Methods in io.vertx.reactivex.core.streams that return WriteStreamSubscriber Modifier and Type Method Description WriteStreamSubscriber<T>WriteStream. 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 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 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 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 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 Description WriteStreamSubscriber<KafkaProducerRecord<K,V>>KafkaProducer. toSubscriber()
-