Class EmbeddedChannel.EmbeddedChannelPipeline

java.lang.Object

io.netty.channel.DefaultChannelPipeline

io.netty.channel.embedded.EmbeddedChannel.EmbeddedChannelPipeline

All Implemented Interfaces:

ChannelInboundInvoker, ChannelOutboundInvoker, ChannelPipeline, java.lang.Iterable<java.util.Map.Entry<java.lang.String, ChannelHandler>>

Enclosing class:

EmbeddedChannel

private final class EmbeddedChannel.EmbeddedChannelPipeline
extends DefaultChannelPipeline

Constructor Summary

Constructors

Constructor	Description
EmbeddedChannelPipeline(EmbeddedChannel channel)

Method Summary

Modifier and Type	Method	Description
protected void	onUnhandledInboundException(java.lang.Throwable cause)	Called once a Throwable hit the end of the ChannelPipeline without been handled by the user in ChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable).
protected void	onUnhandledInboundMessage(ChannelHandlerContext ctx, java.lang.Object msg)	Called once a message hit the end of the ChannelPipeline without been handled by the user in ChannelInboundHandler.channelRead(ChannelHandlerContext, Object).

Methods inherited from class DefaultChannelPipeline

addAfter, addAfter, addBefore, addBefore, addFirst, addFirst, addFirst, addFirst, addFirst, addLast, addLast, addLast, addLast, addLast, bind, bind, channel, close, close, connect, connect, connect, connect, context, context, context, decrementPendingOutboundBytes, deregister, deregister, disconnect, disconnect, fireChannelActive, fireChannelInactive, fireChannelRead, fireChannelReadComplete, fireChannelRegistered, fireChannelUnregistered, fireChannelWritabilityChanged, fireExceptionCaught, fireUserEventTriggered, first, firstContext, flush, get, get, incrementPendingOutboundBytes, iterator, last, lastContext, names, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, onUnhandledChannelWritabilityChanged, onUnhandledInboundChannelActive, onUnhandledInboundChannelInactive, onUnhandledInboundChannelReadComplete, onUnhandledInboundMessage, onUnhandledInboundUserEventTriggered, read, remove, remove, remove, removeFirst, removeIfExists, removeIfExists, removeIfExists, removeLast, replace, replace, replace, toMap, toString, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

EmbeddedChannelPipeline

EmbeddedChannelPipeline(EmbeddedChannel channel)

Method Details

onUnhandledInboundException

protected void onUnhandledInboundException(java.lang.Throwable cause)

Description copied from class: DefaultChannelPipeline

Called once a Throwable hit the end of the ChannelPipeline without been handled by the user in ChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable).

Overrides:

onUnhandledInboundException in class DefaultChannelPipeline

onUnhandledInboundMessage

protected void onUnhandledInboundMessage(ChannelHandlerContext ctx,
 java.lang.Object msg)

Description copied from class: DefaultChannelPipeline

Called once a message hit the end of the ChannelPipeline without been handled by the user in ChannelInboundHandler.channelRead(ChannelHandlerContext, Object). This method is responsible to call ReferenceCountUtil.release(Object) on the given msg at some point.

Overrides:

onUnhandledInboundMessage in class DefaultChannelPipeline