T
- The type of data being published@Internal public abstract class ContextCompletionAwareSubscriber<T> extends CompletionAwareSubscriber<T>
ChannelHandlerContext
.subscription
Modifier | Constructor and Description |
---|---|
protected |
ContextCompletionAwareSubscriber(io.netty.channel.ChannelHandlerContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
doOnComplete()
Implement
Subscriber.onComplete() . |
protected void |
doOnError(Throwable t)
Implement
Subscriber.onError(Throwable) . |
protected void |
doOnNext(T message)
Implement
Subscriber.onNext(Object) . |
protected void |
doOnSubscribe(Subscription subscription)
Implement
Subscriber.onSubscribe(Subscription) . |
protected abstract void |
onComplete(T message) |
isComplete, onComplete, onError, onNext, onSubscribe
protected ContextCompletionAwareSubscriber(io.netty.channel.ChannelHandlerContext context)
context
- The channel handler contextprotected void doOnSubscribe(Subscription subscription)
CompletionAwareSubscriber
Subscriber.onSubscribe(Subscription)
.doOnSubscribe
in class CompletionAwareSubscriber<T>
subscription
- The subscriptionprotected void doOnNext(T message)
CompletionAwareSubscriber
Subscriber.onNext(Object)
.doOnNext
in class CompletionAwareSubscriber<T>
message
- The messageprotected void doOnError(Throwable t)
CompletionAwareSubscriber
Subscriber.onError(Throwable)
.doOnError
in class CompletionAwareSubscriber<T>
t
- The throwableprotected void doOnComplete()
CompletionAwareSubscriber
Subscriber.onComplete()
.doOnComplete
in class CompletionAwareSubscriber<T>
protected abstract void onComplete(T message)
message
- The message