Package io.micronaut.core.async.processor

Class SingleSubscriberProcessor<T,R>

java.lang.Object

io.micronaut.core.async.subscriber.CompletionAwareSubscriber<T>

io.micronaut.core.async.processor.SingleSubscriberProcessor<T,R>

Type Parameters:

T - the type of element signaled to the Subscriber

R - the type of element signaled by the Publisher

All Implemented Interfaces:

Completable, Emitter<T>, Processor<T,R>, Publisher<R>, Subscriber<T>

public abstract class SingleSubscriberProcessor<T,R>
extends CompletionAwareSubscriber<T>
implements Processor<T,R>

A Processor that only allows a single Subscriber

.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field	Description
protected static final Subscription	EMPTY_SUBSCRIPTION
protected Subscription	parentSubscription

Fields inherited from class io.micronaut.core.async.subscriber.CompletionAwareSubscriber

subscription

Constructor Summary

Constructors

Constructor	Description
SingleSubscriberProcessor()

Method Summary

Modifier and Type	Method	Description
protected Optional<Subscriber<? super R>>	currentSubscriber()	Get the current Subscriber.
protected void	doAfterComplete()	Called after doOnComplete() completes.
protected void	doAfterOnError(Throwable throwable)	Called after doOnError(Throwable) completes.
protected void	doAfterOnSubscribe(Subscription subscription)	Called after doOnSubscribe(Subscription) completes.
protected void	doOnComplete()	Implement Subscriber.onComplete().
protected final void	doOnError(Throwable t)	Implement Subscriber.onError(Throwable).
protected final void	doOnSubscribe(Subscription subscription)	Implement Subscriber.onSubscribe(Subscription).
protected void	doOnSubscribe(Subscription subscription, Subscriber<? super R> subscriber)	Perform the actual subscription to the subscriber.
protected abstract void	doSubscribe(Subscriber<? super R> subscriber)	Override to implement Publisher.subscribe(Subscriber).
protected Subscriber<? super R>	getSubscriber()	Get the current Subscriber.
final void	subscribe(Subscriber<? super R> subscriber)

Methods inherited from class io.micronaut.core.async.subscriber.CompletionAwareSubscriber

doOnNext, isComplete, onComplete, onError, onNext, onSubscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Field Details

EMPTY_SUBSCRIPTION

protected static final Subscription EMPTY_SUBSCRIPTION

parentSubscription

protected Subscription parentSubscription

Constructor Details

SingleSubscriberProcessor

public SingleSubscriberProcessor()

Method Details

subscribe

public final void subscribe(Subscriber<? super R> subscriber)

Specified by:

subscribe in interface Publisher<T>

doSubscribe

protected abstract void doSubscribe(Subscriber<? super R> subscriber)

Override to implement Publisher.subscribe(Subscriber).

Parameters:

subscriber - The subscriber

See Also:

• Publisher.subscribe(Subscriber)

getSubscriber

protected Subscriber<? super R> getSubscriber()

Get the current Subscriber.

Returns:

The Subscriber

Throws:

IllegalStateException - if the subscriber is not present

currentSubscriber

protected Optional<Subscriber<? super R>> currentSubscriber()

Get the current Subscriber.

Returns:

An Optional subscriber

doAfterOnError

protected void doAfterOnError(Throwable throwable)

Called after doOnError(Throwable) completes.

Parameters:

throwable - The error

doAfterComplete

protected void doAfterComplete()

Called after doOnComplete() completes.

doAfterOnSubscribe

protected void doAfterOnSubscribe(Subscription subscription)

Called after doOnSubscribe(Subscription) completes.

Parameters:

subscription - subscription

doOnSubscribe

protected void doOnSubscribe(Subscription subscription,
 Subscriber<? super R> subscriber)

Perform the actual subscription to the subscriber.

Parameters:

subscription - The subscription

subscriber - The subscriber (never null)

doOnSubscribe

protected final void doOnSubscribe(Subscription subscription)

Description copied from class: CompletionAwareSubscriber

Implement Subscriber.onSubscribe(Subscription).

Specified by:

doOnSubscribe in class CompletionAwareSubscriber<T>

Parameters:

subscription - The subscription

doOnError

protected final void doOnError(Throwable t)

Description copied from class: CompletionAwareSubscriber

Implement Subscriber.onError(Throwable).

Specified by:

doOnError in class CompletionAwareSubscriber<T>

Parameters:

t - The throwable

doOnComplete

protected void doOnComplete()

Description copied from class: CompletionAwareSubscriber

Implement Subscriber.onComplete().

Specified by:

doOnComplete in class CompletionAwareSubscriber<T>