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>, org.reactivestreams.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 and Description
TypedSubscriber(Argument<T> typeArgument) Constructs a new TypedSubscriber for the given Argument.

Method Summary

Modifier and Type	Method and 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 Detail

TypedSubscriber

public TypedSubscriber(Argument<T> typeArgument)

Constructs a new TypedSubscriber for the given Argument.

Parameters:

typeArgument - The type argument

Method Detail

getTypeArgument

public Argument<T> getTypeArgument()

Returns:

The type argument