public final Class BlockingFirstObserver<T>

Class Inheritance

extends BlockingBaseObserver<T>

Type Parameters

Blocks until the upstream signals its first value or completes.

Field Summary

Inherited from io.reactivex.rxjava3.internal.observers.BlockingBaseObserver:: cancelled error upstream value

Access	Constructor and Description
public	BlockingFirstObserver()

Modifier and Type	Method and Description
public void	onError(Throwable t)
public void	onNext(T the item emitted by the Observable t) Implements io.reactivex.rxjava3.core.Observer.onNext. Provides the `Observer` with a new item to observe.

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

BlockingFirstObserver	back to summary
public BlockingFirstObserver()

onError	back to summary
public void onError(Throwable t) Annotations @Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements io.reactivex.rxjava3.core.Observer.onNext. Doc from io.reactivex.rxjava3.core.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