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