public class WriteStreamSubscriberImpl<R,T> extends WriteStreamSubscriber<R>
| Constructor and Description |
|---|
WriteStreamSubscriberImpl(WriteStream<T> writeStream,
Function<R,T> mapping) |
| Modifier and Type | Method and Description |
|---|---|
WriteStreamSubscriber<R> |
onComplete(Action0 handler)
Sets the handler to invoke if the
Observable that was subscribed to terminates successfully. |
void |
onCompleted() |
WriteStreamSubscriber<R> |
onError(Action1<Throwable> handler)
Sets the handler to invoke if the
Observable that was subscribed to terminates with an error. |
void |
onError(Throwable t) |
void |
onNext(R r) |
void |
onStart() |
WriteStreamSubscriber<R> |
onWriteStreamError(Action1<Throwable> handler)
Sets the handler to invoke if the adapted
WriteStream fails. |
add, isUnsubscribed, request, setProducer, unsubscribepublic WriteStreamSubscriberImpl(WriteStream<T> writeStream, Function<R,T> mapping)
public void onStart()
onStart in class Subscriber<R>public void onNext(R r)
public void onError(Throwable t)
public void onCompleted()
public WriteStreamSubscriber<R> onError(Action1<Throwable> handler)
WriteStreamSubscriberObservable that was subscribed to terminates with an error.
The underlying WriteStream.end() method is not invoked in this case.
onError in class WriteStreamSubscriber<R>public WriteStreamSubscriber<R> onComplete(Action0 handler)
WriteStreamSubscriberObservable that was subscribed to terminates successfully.
The underlying WriteStream.end() method is invoked before the given handler.
onComplete in class WriteStreamSubscriber<R>public WriteStreamSubscriber<R> onWriteStreamError(Action1<Throwable> handler)
WriteStreamSubscriberWriteStream fails.
The underlying WriteStream.end() method is not invoked in this case.
onWriteStreamError in class WriteStreamSubscriber<R>Copyright © 2020. All rights reserved.