io.vertx.reactivex

Interface WriteStreamSubscriber<R>

All Superinterfaces:

FlowableSubscriber<R>, org.reactivestreams.Subscriber<R>

All Known Implementing Classes:

WriteStreamSubscriberImpl

public interface WriteStreamSubscriber<R>
extends FlowableSubscriber<R>

A WriteStream to Subscriber adapter.

Author:

Thomas Segismont

Method Summary

Modifier and Type	Method and Description
WriteStreamSubscriber<R>	onComplete(Action handler) Deprecated. because the handler may be called while there are outstanding writes in the underlying WriteStream. Use onWriteStreamEnd(Action) instead.
WriteStreamSubscriber<R>	onError(Consumer<? super Throwable> handler) Sets the handler to invoke if the Flowable that was subscribed to terminates with an error.
WriteStreamSubscriber<R>	onWriteStreamEnd(Action handler) Sets the handler to invoke when the adapted WriteStream ends successfully.
WriteStreamSubscriber<R>	onWriteStreamEndError(Consumer<? super Throwable> handler) Sets the handler to invoke when the adapted WriteStream ends with an error.
WriteStreamSubscriber<R>	onWriteStreamError(Consumer<? super Throwable> handler) Sets the handler to invoke if the adapted WriteStream fails.

Methods inherited from interface io.reactivex.FlowableSubscriber

onSubscribe

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext

Method Detail

onError

WriteStreamSubscriber<R> onError(Consumer<? super Throwable> handler)

Sets the handler to invoke if the Flowable that 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

onComplete

@Deprecated
WriteStreamSubscriber<R> onComplete(Action handler)

Deprecated. because the handler may be called while there are outstanding writes in the underlying WriteStream. Use onWriteStreamEnd(Action) instead.

Sets the handler to invoke if the Flowable that was subscribed to terminates successfully.

The underlying WriteStream.end() method is invoked before the given handler.

Returns:

a reference to this, so the API can be used fluently

onWriteStreamError

WriteStreamSubscriber<R> onWriteStreamError(Consumer<? super Throwable> handler)

Sets the handler to invoke if the adapted WriteStream fails.

The underlying WriteStream.end() method is not invoked in this case.

Returns:

a reference to this, so the API can be used fluently

onWriteStreamEnd

WriteStreamSubscriber<R> onWriteStreamEnd(Action handler)

Sets the handler to invoke when the adapted WriteStream ends successfully.

Returns:

a reference to this, so the API can be used fluently

onWriteStreamEndError

WriteStreamSubscriber<R> onWriteStreamEndError(Consumer<? super Throwable> handler)

Sets the handler to invoke when the adapted WriteStream ends with an error.

Returns:

a reference to this, so the API can be used fluently