pack-priv final Class BlockingFirstSubscriber<T>

Class Inheritance

extends BlockingSingleSubscriber<T>

Type Parameters

Imports

reactor.util.context.Context

Blocks until the upstream signals its first value or completes.

Field Summary

Inherited from reactor.core.publisher.BlockingSingleSubscriber:: cancelled context error s value

Access	Constructor and Description
public	BlockingFirstSubscriber(Context context)

Modifier and Type	Method and Description
public void	onError(Throwable the throwable signaled t) Implements org.reactivestreams.Subscriber.onError. Failed terminal state.
public void	onNext(T the element signaled t) Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.
public String	stepName() Overrides default reactor.core.Scannable.stepName. Return a meaningful `String` representation of this `Scannable` in its chain of `parents()` and `actuals()`.

Inherited from reactor.core.publisher.BlockingSingleSubscriber:: blockingGet blockingGet currentContext dispose isDisposed onComplete onSubscribe scanUnsafe

BlockingFirstSubscriber	back to summary
public BlockingFirstSubscriber(Context context)

onError back to summary

onError	back to summary
public void onError(Throwable t) Implements org.reactivestreams.Subscriber.onError. Doc from org.reactivestreams.Subscriber.onError. Failed terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Parameters t:Throwable the throwable signaled Annotations @Override

public void onError(Throwable t)

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters

Annotations

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements org.reactivestreams.Subscriber.onNext. Doc from org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`. Parameters t:T the element signaled Annotations @Override

public void onNext(T t)

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters

Annotations

stepName back to summary

stepName	back to summary
public String stepName() Overrides default reactor.core.Scannable.stepName. Doc from reactor.core.Scannable.stepName. Return a meaningful `String` representation of this `Scannable` in its chain of `parents()` and `actuals()`. Annotations @Override

public String stepName()

Return a meaningful String representation of this Scannable in its chain of parents() and actuals().

Annotations