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. |
Modifier and Type | Method and Description |
---|---|
WriteStreamSubscriber<AmqpMessage> |
AmqpSender.toSubscriber() |
Modifier and Type | Method and Description |
---|---|
WriteStreamSubscriber<Buffer> |
AsyncFile.toSubscriber() |
Modifier and Type | Method and Description |
---|---|
WriteStreamSubscriber<Buffer> |
HttpServerResponse.toSubscriber() |
WriteStreamSubscriber<Buffer> |
ServerWebSocket.toSubscriber() |
WriteStreamSubscriber<Buffer> |
HttpClientRequest.toSubscriber() |
WriteStreamSubscriber<Buffer> |
WebSocket.toSubscriber() |
Modifier and Type | Method and Description |
---|---|
WriteStreamSubscriber<Buffer> |
NetSocket.toSubscriber() |
Modifier and Type | Method and Description |
---|---|
WriteStreamSubscriber<Buffer> |
SockJSSocket.toSubscriber() |
Modifier and Type | Method and Description |
---|---|
WriteStreamSubscriber<KafkaProducerRecord<K,V>> |
KafkaProducer.toSubscriber() |
Copyright © 2021 Eclipse. All rights reserved.