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