Uses of Class
io.vertx.rx.java.WriteStreamSubscriber
-
-
Uses of WriteStreamSubscriber in io.vertx.rx.java
Methods in io.vertx.rx.java that return WriteStreamSubscriber Modifier and Type Method Description abstract WriteStreamSubscriber<R>
WriteStreamSubscriber. onError(Action1<Throwable> handler)
Sets the handler to invoke if theObservable
that was subscribed to terminates with an error.abstract WriteStreamSubscriber<R>
WriteStreamSubscriber. onWriteStreamEnd(Action0 handler)
Sets the handler to invoke when the adaptedWriteStream
ends successfully.abstract WriteStreamSubscriber<R>
WriteStreamSubscriber. onWriteStreamEndError(Action1<Throwable> handler)
Sets the handler to invoke when the adaptedWriteStream
ends with an error.abstract WriteStreamSubscriber<R>
WriteStreamSubscriber. onWriteStreamError(Action1<Throwable> handler)
Sets the handler to invoke if the adaptedWriteStream
fails.static <T> WriteStreamSubscriber<T>
RxHelper. toSubscriber(WriteStream<T> stream)
Adapts a Vert.xWriteStream
to an RxJavaSubscriber
.static <R,T>
WriteStreamSubscriber<R>RxHelper. toSubscriber(WriteStream<T> stream, java.util.function.Function<R,T> mapping)
LikeRxHelper.toSubscriber(WriteStream)
, except the providedmapping
function is applied to eachObservable
item. -
Uses of WriteStreamSubscriber in io.vertx.rxjava.amqp
Methods in io.vertx.rxjava.amqp that return WriteStreamSubscriber Modifier and Type Method 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 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 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.rxjava.core.net
Methods in io.vertx.rxjava.core.net that return WriteStreamSubscriber Modifier and Type Method Description WriteStreamSubscriber<Buffer>
NetSocket. toSubscriber()
-
Uses of WriteStreamSubscriber in io.vertx.rxjava.core.streams
Methods in io.vertx.rxjava.core.streams that return WriteStreamSubscriber Modifier and Type Method Description WriteStreamSubscriber<T>
WriteStream. 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 Description WriteStreamSubscriber<Buffer>
SockJSSocket. toSubscriber()
-
Uses of WriteStreamSubscriber in io.vertx.rxjava.grpc.client
Methods in io.vertx.rxjava.grpc.client that return WriteStreamSubscriber Modifier and Type Method Description WriteStreamSubscriber<Req>
GrpcClientRequest. toSubscriber()
-
Uses of WriteStreamSubscriber in io.vertx.rxjava.grpc.common
Methods in io.vertx.rxjava.grpc.common that return WriteStreamSubscriber Modifier and Type Method Description WriteStreamSubscriber<T>
GrpcWriteStream. toSubscriber()
-
Uses of WriteStreamSubscriber in io.vertx.rxjava.grpc.server
Methods in io.vertx.rxjava.grpc.server that return WriteStreamSubscriber Modifier and Type Method Description WriteStreamSubscriber<Resp>
GrpcServerResponse. 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 Description WriteStreamSubscriber<KafkaProducerRecord<K,V>>
KafkaProducer. toSubscriber()
-