public abstract class WriteStreamSubscriber<R>
extends rx.Subscriber<R>
WriteStream
to Subscriber
adapter.Constructor and Description |
---|
WriteStreamSubscriber() |
Modifier and Type | Method and Description |
---|---|
abstract WriteStreamSubscriber<R> |
onComplete(rx.functions.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(rx.functions.Action1<Throwable> handler)
Sets the handler to invoke if the
Observable that was subscribed to terminates with an error. |
abstract WriteStreamSubscriber<R> |
onWriteStreamEnd(rx.functions.Action0 handler)
Sets the handler to invoke when the adapted
WriteStream ends successfully. |
abstract WriteStreamSubscriber<R> |
onWriteStreamEndError(rx.functions.Action1<Throwable> handler)
Sets the handler to invoke when the adapted
WriteStream ends with an error. |
abstract WriteStreamSubscriber<R> |
onWriteStreamError(rx.functions.Action1<Throwable> handler)
Sets the handler to invoke if the adapted
WriteStream fails. |
add, isUnsubscribed, onStart, request, setProducer, unsubscribe
public abstract WriteStreamSubscriber<R> onError(rx.functions.Action1<Throwable> handler)
Observable
that was subscribed to terminates with an error.
The underlying WriteStream.end()
method is not invoked in this case.
@Deprecated public abstract WriteStreamSubscriber<R> onComplete(rx.functions.Action0 handler)
handler
may be called while there are outstanding writes in the underlying WriteStream
.
Use onWriteStreamEnd(Action0)
instead.Observable
that was subscribed to terminates successfully.
The underlying WriteStream.end()
method is invoked before the given handler
.
public abstract WriteStreamSubscriber<R> onWriteStreamError(rx.functions.Action1<Throwable> handler)
WriteStream
fails.
The underlying WriteStream.end()
method is not invoked in this case.
public abstract WriteStreamSubscriber<R> onWriteStreamEnd(rx.functions.Action0 handler)
WriteStream
ends successfully.public abstract WriteStreamSubscriber<R> onWriteStreamEndError(rx.functions.Action1<Throwable> handler)
WriteStream
ends with an error.Copyright © 2020 Eclipse. All rights reserved.