public interface WriteStreamSubscriber<R> extends FlowableSubscriber<R>
WriteStream to Subscriber adapter.| Modifier and Type | Method and Description |
|---|---|
WriteStreamSubscriber<R> |
onComplete(Action handler)
Sets the handler to invoke if the
Flowable that was subscribed to terminates successfully. |
WriteStreamSubscriber<R> |
onError(Consumer<? super Throwable> handler)
Sets the handler to invoke if the
Flowable that was subscribed to terminates with an error. |
WriteStreamSubscriber<R> |
onWriteStreamError(Consumer<? super Throwable> handler)
Sets the handler to invoke if the adapted
WriteStream fails. |
onSubscribeWriteStreamSubscriber<R> onError(Consumer<? super Throwable> handler)
Flowable that was subscribed to terminates with an error.
The underlying WriteStream.end() method is not invoked in this case.
WriteStreamSubscriber<R> onComplete(Action handler)
Flowable that was subscribed to terminates successfully.
The underlying WriteStream.end() method is invoked before the given handler.
WriteStreamSubscriber<R> onWriteStreamError(Consumer<? super Throwable> handler)
WriteStream fails.
The underlying WriteStream.end() method is not invoked in this case.
Copyright © 2020. All rights reserved.