RxJava 2 2.2.21 · io.reactivex.internal.observers.BlockingLastObserver

public final Class BlockingLastObserver<T>

Blocks until the upstream signals its last value or completes.

Constructor Summary

Access	Constructor and Description
public	BlockingLastObserver()

Modifier and Type	Method and Description
public void	onError(Throwable the exception encountered by the Observable t) Implements io.reactivex.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(T the item emitted by the Observable t) Implements io.reactivex.Observer.onNext. Provides the Observer with a new item to observe.

Inherited from io.reactivex.internal.observers.BlockingBaseObserver:: blockingGet dispose isDisposed onComplete onSubscribe

BlockingLastObserver	back to summary
public BlockingLastObserver()

onError back to summary

onError	back to summary
public void onError(Throwable t) Implements io.reactivex.Observer.onError. Doc from io.reactivex.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition. If the `Observable` calls this method, it will not thereafter call `onNext` or `onComplete`. Parameters t:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable t)

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onComplete.

Parameters

Annotations

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements io.reactivex.Observer.onNext. Doc from io.reactivex.Observer.onNext. Provides the Observer with a new item to observe. The `Observable` may call this method 0 or more times. The `Observable` will not call this method again after it calls either `onComplete` or `onError`. Parameters t:T the item emitted by the Observable Annotations @Override

public void onNext(T t)

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onComplete or onError.

Parameters

Annotations