Package | Description |
---|---|
io.vertx.rx.java |
Modifier and Type | Method and Description |
---|---|
abstract WriteStreamSubscriber<R> |
WriteStreamSubscriber.onComplete(rx.functions.Action0 handler)
Deprecated.
because the
handler may be called while there are outstanding writes in the underlying WriteStream .
Use onWriteStreamEnd(Action0) instead. |
abstract WriteStreamSubscriber<R> |
WriteStreamSubscriber.onError(rx.functions.Action1<Throwable> handler)
Sets the handler to invoke if the
Observable that was subscribed to terminates with an error. |
abstract WriteStreamSubscriber<R> |
WriteStreamSubscriber.onWriteStreamEnd(rx.functions.Action0 handler)
Sets the handler to invoke when the adapted
WriteStream ends successfully. |
abstract WriteStreamSubscriber<R> |
WriteStreamSubscriber.onWriteStreamEndError(rx.functions.Action1<Throwable> handler)
Sets the handler to invoke when the adapted
WriteStream ends with an error. |
abstract WriteStreamSubscriber<R> |
WriteStreamSubscriber.onWriteStreamError(rx.functions.Action1<Throwable> handler)
Sets the handler to invoke if the adapted
WriteStream fails. |
static <T> WriteStreamSubscriber<T> |
RxHelper.toSubscriber(io.vertx.core.streams.WriteStream<T> stream)
Adapts a Vert.x
WriteStream to an RxJava Subscriber . |
static <R,T> WriteStreamSubscriber<R> |
RxHelper.toSubscriber(io.vertx.core.streams.WriteStream<T> stream,
Function<R,T> mapping)
Like
RxHelper.toSubscriber(WriteStream) , except the provided mapping function is applied to each Observable item. |
Copyright © 2021 Eclipse. All rights reserved.