Class CompletionAwareSubscriber<T>

java.lang.Object
io.micronaut.core.async.subscriber.CompletionAwareSubscriber<T>
Type Parameters:
T - the type of element signaled.
All Implemented Interfaces:
Completable, Emitter<T>, Subscriber<T>
Direct Known Subclasses:
ContextCompletionAwareSubscriber, SingleSubscriberProcessor, TypedSubscriber

public abstract class CompletionAwareSubscriber<T> extends Object implements Subscriber<T>, Emitter<T>
A Subscriber that tracks completion state using a AtomicBoolean.
Since:
1.0
Author:
Graeme Rocher