public class WriteStreamObserverImpl<R,T> extends Object implements WriteStreamObserver<R>
| Constructor and Description |
|---|
WriteStreamObserverImpl(WriteStream<T> writeStream,
Function<R,T> mapping) |
| Modifier and Type | Method and Description |
|---|---|
void |
onComplete() |
WriteStreamObserver<R> |
onError(io.reactivex.functions.Consumer<? super 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 |
onSubscribe(io.reactivex.disposables.Disposable disposable) |
WriteStreamObserver<R> |
onWriteStreamEnd(io.reactivex.functions.Action handler)
Sets the handler to invoke when the adapted
WriteStream ends successfully. |
WriteStreamObserver<R> |
onWriteStreamEndError(io.reactivex.functions.Consumer<? super Throwable> handler)
Sets the handler to invoke when the adapted
WriteStream ends with an error. |
WriteStreamObserver<R> |
onWriteStreamError(io.reactivex.functions.Consumer<? super Throwable> handler)
Sets the handler to invoke if the adapted
WriteStream fails. |
public WriteStreamObserverImpl(WriteStream<T> writeStream, Function<R,T> mapping)
public void onSubscribe(io.reactivex.disposables.Disposable disposable)
onSubscribe in interface io.reactivex.Observer<R>public void onError(Throwable t)
onError in interface io.reactivex.Observer<R>public void onComplete()
onComplete in interface io.reactivex.Observer<R>public WriteStreamObserver<R> onError(io.reactivex.functions.Consumer<? super Throwable> handler)
WriteStreamObserverObservable that was subscribed to terminates with an error.
The underlying WriteStream.end() method is not invoked in this case.
onError in interface WriteStreamObserver<R>public WriteStreamObserver<R> onWriteStreamError(io.reactivex.functions.Consumer<? super Throwable> handler)
WriteStreamObserverWriteStream fails.
The underlying WriteStream.end() method is not invoked in this case.
onWriteStreamError in interface WriteStreamObserver<R>public WriteStreamObserver<R> onWriteStreamEnd(io.reactivex.functions.Action handler)
WriteStreamObserverWriteStream ends successfully.onWriteStreamEnd in interface WriteStreamObserver<R>public WriteStreamObserver<R> onWriteStreamEndError(io.reactivex.functions.Consumer<? super Throwable> handler)
WriteStreamObserverWriteStream ends with an error.onWriteStreamEndError in interface WriteStreamObserver<R>Copyright © 2021. All rights reserved.