io.vertx.reactivex.impl

Class WriteStreamObserverImpl<R,T>

java.lang.Object

io.vertx.reactivex.impl.WriteStreamObserverImpl<R,T>

All Implemented Interfaces:

io.reactivex.Observer<R>, WriteStreamObserver<R>

public class WriteStreamObserverImpl<R,T>
extends Object
implements WriteStreamObserver<R>

Author:

Thomas Segismont

Constructor Summary

Constructors

Constructor and Description
WriteStreamObserverImpl(WriteStream<T> writeStream, Function<R,T> mapping)

Method Summary

Modifier and Type	Method and Description
void	onComplete()
WriteStreamObserver<R>	onError(io.reactivex.functions.Consumer<? super Throwable> handler) Sets the handler to invoke if the Observable that was subscribed to terminates with an error.
void	onError(Throwable t)
void	onNext(R r)
void	onSubscribe(io.reactivex.disposables.Disposable disposable)
WriteStreamObserver<R>	onWriteStreamEnd(io.reactivex.functions.Action handler) Sets the handler to invoke when the adapted WriteStream ends successfully.
WriteStreamObserver<R>	onWriteStreamEndError(io.reactivex.functions.Consumer<? super Throwable> handler) Sets the handler to invoke when the adapted WriteStream ends with an error.
WriteStreamObserver<R>	onWriteStreamError(io.reactivex.functions.Consumer<? super Throwable> handler) Sets the handler to invoke if the adapted WriteStream fails.

Methods inherited from class java.lang.Object

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

Constructor Detail

WriteStreamObserverImpl

public WriteStreamObserverImpl(WriteStream<T> writeStream,
                               Function<R,T> mapping)

Method Detail

onSubscribe

public void onSubscribe(io.reactivex.disposables.Disposable disposable)

Specified by:

onSubscribe in interface io.reactivex.Observer<R>

onNext

public void onNext(R r)

Specified by:

onNext in interface io.reactivex.Observer<R>

onError

public void onError(Throwable t)

Specified by:

onError in interface io.reactivex.Observer<R>

onComplete

public void onComplete()

Specified by:

onComplete in interface io.reactivex.Observer<R>

onError

public WriteStreamObserver<R> onError(io.reactivex.functions.Consumer<? super Throwable> handler)

Description copied from interface: WriteStreamObserver

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.

Specified by:

onError in interface WriteStreamObserver<R>

Returns:

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

onWriteStreamError

public WriteStreamObserver<R> onWriteStreamError(io.reactivex.functions.Consumer<? super Throwable> handler)

Description copied from interface: WriteStreamObserver

Sets the handler to invoke if the adapted WriteStream fails.

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

Specified by:

onWriteStreamError in interface WriteStreamObserver<R>

Returns:

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

onWriteStreamEnd

public WriteStreamObserver<R> onWriteStreamEnd(io.reactivex.functions.Action handler)

Description copied from interface: WriteStreamObserver

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

Specified by:

onWriteStreamEnd in interface WriteStreamObserver<R>

Returns:

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

onWriteStreamEndError

public WriteStreamObserver<R> onWriteStreamEndError(io.reactivex.functions.Consumer<? super Throwable> handler)

Description copied from interface: WriteStreamObserver

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

Specified by:

onWriteStreamEndError in interface WriteStreamObserver<R>

Returns:

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