io.vertx.rx.java

Class WriteStreamSubscriber<R>

java.lang.Object

rx.Subscriber<R>

io.vertx.rx.java.WriteStreamSubscriber<R>

All Implemented Interfaces:

Observer<R>, Subscription

Direct Known Subclasses:

WriteStreamSubscriberImpl

public abstract class WriteStreamSubscriber<R>
extends Subscriber<R>

A WriteStream to Subscriber adapter.

Author:

Thomas Segismont

Constructor Summary

Constructors

Constructor and Description
WriteStreamSubscriber()

Method Summary

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

Methods inherited from class rx.Subscriber

add, isUnsubscribed, onStart, request, setProducer, unsubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface rx.Observer

onCompleted, onError, onNext

Constructor Detail

WriteStreamSubscriber

public WriteStreamSubscriber()

Method Detail

onError

public abstract WriteStreamSubscriber<R> onError(Action1<Throwable> handler)

Sets the handler to invoke if the Observable 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
public abstract WriteStreamSubscriber<R> onComplete(Action0 handler)

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

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

public abstract WriteStreamSubscriber<R> onWriteStreamError(Action1<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

public abstract WriteStreamSubscriber<R> onWriteStreamEnd(Action0 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

public abstract WriteStreamSubscriber<R> onWriteStreamEndError(Action1<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