public interface WriteStreamObserver<R> extends Observer<R>
WriteStream
to Observer
adapter.Modifier and Type | Method and Description |
---|---|
WriteStreamObserver<R> |
onError(Consumer<? super Throwable> handler)
Sets the handler to invoke if the
Observable that was subscribed to terminates with an error. |
WriteStreamObserver<R> |
onWriteStreamEnd(Action handler)
Sets the handler to invoke when the adapted
WriteStream ends successfully. |
WriteStreamObserver<R> |
onWriteStreamEndError(Consumer<? super Throwable> handler)
Sets the handler to invoke when the adapted
WriteStream ends with an error. |
WriteStreamObserver<R> |
onWriteStreamError(Consumer<? super Throwable> handler)
Sets the handler to invoke if the adapted
WriteStream fails. |
onComplete, onError, onNext, onSubscribe
WriteStreamObserver<R> onError(Consumer<? super Throwable> handler)
Observable
that was subscribed to terminates with an error.
The underlying WriteStream.end()
method is not invoked in this case.
WriteStreamObserver<R> onWriteStreamError(Consumer<? super Throwable> handler)
WriteStream
fails.
The underlying WriteStream.end()
method is not invoked in this case.
WriteStreamObserver<R> onWriteStreamEnd(Action handler)
WriteStream
ends successfully.WriteStreamObserver<R> onWriteStreamEndError(Consumer<? super Throwable> handler)
WriteStream
ends with an error.Copyright © 2021 Eclipse. All rights reserved.