Class TypedSubscriber<T>

java.lang.Object
io.micronaut.core.async.subscriber.CompletionAwareSubscriber<T>
io.micronaut.core.async.subscriber.TypedSubscriber<T>
Type Parameters:
T - Type of TypedSubscriber
All Implemented Interfaces:
Completable, Emitter<T>, Subscriber<T>

public abstract class TypedSubscriber<T> extends CompletionAwareSubscriber<T>
A subscriber that is aware of the target type.
Since:
1.0
Author:
graemerocher
  • Constructor Details

    • TypedSubscriber

      public TypedSubscriber(Argument<T> typeArgument)
      Constructs a new TypedSubscriber for the given Argument.
      Parameters:
      typeArgument - The type argument
  • Method Details

    • getTypeArgument

      public Argument<T> getTypeArgument()
      Returns:
      The type argument