Package io.micronaut.core.async.subscriber

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

Field Summary

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

subscription

Constructor Summary

Constructors

Constructor	Description
TypedSubscriber(Argument<T> typeArgument)	Constructs a new TypedSubscriber for the given Argument.

Method Summary

Modifier and Type	Method	Description
Argument<T>	getTypeArgument()

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

doOnComplete, doOnError, doOnNext, doOnSubscribe, isComplete, onComplete, onError, onNext, onSubscribe

Methods inherited from class java.lang.Object

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

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