Package io.vertx.rxjava3
Interface WriteStreamObserver<R>
-
- All Superinterfaces:
Observer<R>
public interface WriteStreamObserver<R> extends Observer<R>
AWriteStreamtoObserveradapter.- Author:
- Thomas Segismont
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description WriteStreamObserver<R>onError(Consumer<? super Throwable> handler)Sets the handler to invoke if theObservablethat was subscribed to terminates with an error.WriteStreamObserver<R>onWriteStreamEnd(Action handler)Sets the handler to invoke when the adaptedWriteStreamends successfully.WriteStreamObserver<R>onWriteStreamEndError(Consumer<? super Throwable> handler)Sets the handler to invoke when the adaptedWriteStreamends with an error.WriteStreamObserver<R>onWriteStreamError(Consumer<? super Throwable> handler)Sets the handler to invoke if the adaptedWriteStreamfails.-
Methods inherited from interface io.reactivex.rxjava3.core.Observer
onComplete, onError, onNext, onSubscribe
-
-
-
-
Method Detail
-
onError
WriteStreamObserver<R> onError(Consumer<? super Throwable> handler)
Sets the handler to invoke if theObservablethat was subscribed to terminates with an error.The underlying
WriteStream.end()method is not invoked in this case.- Returns:
- a reference to this, so the API can be used fluently
-
onWriteStreamError
WriteStreamObserver<R> onWriteStreamError(Consumer<? super Throwable> handler)
Sets the handler to invoke if the adaptedWriteStreamfails.The underlying
WriteStream.end()method is not invoked in this case.- Returns:
- a reference to this, so the API can be used fluently
-
onWriteStreamEnd
WriteStreamObserver<R> onWriteStreamEnd(Action handler)
Sets the handler to invoke when the adaptedWriteStreamends successfully.- Returns:
- a reference to this, so the API can be used fluently
-
onWriteStreamEndError
WriteStreamObserver<R> onWriteStreamEndError(Consumer<? super Throwable> handler)
Sets the handler to invoke when the adaptedWriteStreamends with an error.- Returns:
- a reference to this, so the API can be used fluently
-
-