pack-priv final Class BlockingMonoSubscriber<T>

Class Inheritance

extends BlockingSingleSubscriber<T>

java.lang.Object
java.util.concurrent.CountDownLatch
reactor.core.publisher.BlockingSingleSubscriber
reactor.core.publisher.BlockingMonoSubscriber

Type Parameters

<T>: the value type

Imports

reactor.util.context.Context

Blocks assuming the upstream is a Mono, until it signals its value or completes. Compared to BlockingFirstSubscriber, this variant doesn't cancel the upstream in onNext.

See Also: https://github.com/reactor/reactive-streams-commons

Field Summary

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

Constructor Summary

Access	Constructor and Description
public	BlockingMonoSubscriber(Context context)

Method Summary

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

Constructor Detail

BlockingMonoSubscriber	back to summary
public BlockingMonoSubscriber(Context context)

Method Detail

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)

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

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)

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

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()

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