io.micronaut.http.server.netty.async

Class ContextCompletionAwareSubscriber<T>

java.lang.Object

io.micronaut.core.async.subscriber.CompletionAwareSubscriber<T>

io.micronaut.http.server.netty.async.ContextCompletionAwareSubscriber<T>

Type Parameters:

T - The type of data being published

All Implemented Interfaces:

Completable, Emitter<T>, org.reactivestreams.Subscriber<T>

@Internal
public abstract class ContextCompletionAwareSubscriber<T>
extends CompletionAwareSubscriber<T>

A subscriber that subscribes to a single result with special handling for the ChannelHandlerContext.

Since:

1.0

Author:

James Kleeh

Field Summary

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

subscription

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ContextCompletionAwareSubscriber(io.netty.channel.ChannelHandlerContext context)

Method Summary

Modifier and Type	Method and Description
protected void	doOnComplete() Implement Subscriber.onComplete().
protected void	doOnError(java.lang.Throwable t) Implement Subscriber.onError(Throwable).
protected void	doOnNext(T message) Implement Subscriber.onNext(Object).
protected void	doOnSubscribe(org.reactivestreams.Subscription subscription) Implement Subscriber.onSubscribe(Subscription).
protected abstract void	onComplete(T message)

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

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

ContextCompletionAwareSubscriber

protected ContextCompletionAwareSubscriber(io.netty.channel.ChannelHandlerContext context)

Parameters:

context - The channel handler context

Method Detail

doOnSubscribe

protected void doOnSubscribe(org.reactivestreams.Subscription subscription)

Description copied from class: CompletionAwareSubscriber

Implement Subscriber.onSubscribe(Subscription).

Specified by:

doOnSubscribe in class CompletionAwareSubscriber<T>

Parameters:

subscription - The subscription

doOnNext

protected void doOnNext(T message)

Description copied from class: CompletionAwareSubscriber

Implement Subscriber.onNext(Object).

Specified by:

doOnNext in class CompletionAwareSubscriber<T>

Parameters:

message - The message

doOnError

protected void doOnError(java.lang.Throwable t)

Description copied from class: CompletionAwareSubscriber

Implement Subscriber.onError(Throwable).

Specified by:

doOnError in class CompletionAwareSubscriber<T>

Parameters:

t - The throwable

doOnComplete

protected void doOnComplete()

Description copied from class: CompletionAwareSubscriber

Implement Subscriber.onComplete().

Specified by:

doOnComplete in class CompletionAwareSubscriber<T>

onComplete

protected abstract void onComplete(T message)

Parameters:

message - The message