Package io.micronaut.core.async.publisher

Class SingleSubscriberPublisher<T>

java.lang.Object

io.micronaut.core.async.publisher.SingleSubscriberPublisher<T>

Type Parameters:

T - the type of element signaled.

All Implemented Interfaces:

Publisher<T>

public abstract class SingleSubscriberPublisher<T>
extends Object
implements Publisher<T>

A Publisher 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

Constructor Summary

Constructors

Constructor	Description
SingleSubscriberPublisher()

Method Summary

Modifier and Type	Method	Description
protected Optional<Subscriber<? super T>>	currentSubscriber()
protected abstract void	doSubscribe(Subscriber<? super T> subscriber)	Override to implement Publisher.subscribe(Subscriber).
final void	subscribe(Subscriber<? super T> subscriber)

Methods inherited from class java.lang.Object

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

Field Details

EMPTY_SUBSCRIPTION

protected static final Subscription EMPTY_SUBSCRIPTION

Constructor Details

SingleSubscriberPublisher

public SingleSubscriberPublisher()

Method Details

subscribe

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

Specified by:

subscribe in interface Publisher<T>

doSubscribe

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

Override to implement Publisher.subscribe(Subscriber).

Parameters:

subscriber - The subscriber

See Also:

• Publisher.subscribe(Subscriber)

currentSubscriber

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

Returns:

Obtain the current subscriber