public abstract class WriteStreamSubscriber<R> extends Subscriber<R>
WriteStream to Subscriber adapter.| Constructor and Description |
|---|
WriteStreamSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
abstract WriteStreamSubscriber<R> |
onComplete(Action0 handler)
Sets the handler to invoke if the
Observable that was subscribed to terminates successfully. |
abstract WriteStreamSubscriber<R> |
onError(Action1<Throwable> handler)
Sets the handler to invoke if the
Observable that was subscribed to terminates with an error. |
abstract WriteStreamSubscriber<R> |
onWriteStreamError(Action1<Throwable> handler)
Sets the handler to invoke if the adapted
WriteStream fails. |
add, isUnsubscribed, onStart, request, setProducer, unsubscribeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonCompleted, onError, onNextpublic abstract WriteStreamSubscriber<R> onError(Action1<Throwable> handler)
Observable that was subscribed to terminates with an error.
The underlying WriteStream.end() method is not invoked in this case.
public abstract WriteStreamSubscriber<R> onComplete(Action0 handler)
Observable that was subscribed to terminates successfully.
The underlying WriteStream.end() method is invoked before the given handler.
public abstract WriteStreamSubscriber<R> onWriteStreamError(Action1<Throwable> handler)
WriteStream fails.
The underlying WriteStream.end() method is not invoked in this case.
Copyright © 2020. All rights reserved.