2018-02-12

Channel ChannelPipeline ChannelHandlerContext ChannelHandlerAdapter class hierarchy

ChannelInboundInvoker.class

public interface ChannelInboundInvoker {
    ChannelInboundInvoker fireChannelRegistered();

    ChannelInboundInvoker fireChannelUnregistered();

    ChannelInboundInvoker fireChannelActive();

    ChannelInboundInvoker fireChannelInactive();

    ChannelInboundInvoker fireExceptionCaught(Throwable var1);

    ChannelInboundInvoker fireUserEventTriggered(Object var1);

    ChannelInboundInvoker fireChannelRead(Object var1);

    ChannelInboundInvoker fireChannelReadComplete();

    ChannelInboundInvoker fireChannelWritabilityChanged();
}

ChannelOutboundInvoker.class

public interface ChannelOutboundInvoker {

ChannelFuture bind(SocketAddress var1);

ChannelFuture connect(SocketAddress var1);

ChannelFuture connect(SocketAddress var1, SocketAddress var2);

ChannelFuture disconnect();

ChannelFuture close();

ChannelFuture deregister();

ChannelFuture bind(SocketAddress var1, ChannelPromise var2);

ChannelFuture connect(SocketAddress var1, ChannelPromise var2);

ChannelFuture connect(SocketAddress var1, SocketAddress var2, ChannelPromise var3);

ChannelFuture disconnect(ChannelPromise var1);

ChannelFuture close(ChannelPromise var1);

ChannelFuture deregister(ChannelPromise var1);

ChannelOutboundInvoker read();

ChannelFuture write(Object var1);

ChannelFuture write(Object var1, ChannelPromise var2);

ChannelOutboundInvoker flush();

ChannelFuture writeAndFlush(Object var1, ChannelPromise var2);

ChannelFuture writeAndFlush(Object var1);

ChannelPromise newPromise();

ChannelProgressivePromise newProgressivePromise();

ChannelFuture newSucceededFuture();

ChannelFuture newFailedFuture(Throwable var1);

ChannelPromise voidPromise();

}

Channel.class

public interface Channel extends AttributeMap, ChannelOutboundInvoker, Comparable<Channel> {
    ChannelId id();

    EventLoop eventLoop();

    Channel parent();

    ChannelConfig config();

    boolean isOpen();

    boolean isRegistered();

    boolean isActive();

    ChannelMetadata metadata();

    SocketAddress localAddress();

    SocketAddress remoteAddress();

    ChannelFuture closeFuture();

    boolean isWritable();

    long bytesBeforeUnwritable();

    long bytesBeforeWritable();

    Channel.Unsafe unsafe();

    ChannelPipeline pipeline();

    ByteBufAllocator alloc();

    Channel read();

    Channel flush();

    public interface Unsafe {
        Handle recvBufAllocHandle();

        SocketAddress localAddress();

        SocketAddress remoteAddress();

        void register(EventLoop var1, ChannelPromise var2);

        void bind(SocketAddress var1, ChannelPromise var2);

        void connect(SocketAddress var1, SocketAddress var2, ChannelPromise var3);

        void disconnect(ChannelPromise var1);

        void close(ChannelPromise var1);

        void closeForcibly();

        void deregister(ChannelPromise var1);

        void beginRead();

        void write(Object var1, ChannelPromise var2);

        void flush();

        ChannelPromise voidPromise();

        ChannelOutboundBuffer outboundBuffer();
    }
}

ChannelHandler

public interface ChannelHandler {
    void handlerAdded(ChannelHandlerContext var1) throws Exception;

    void handlerRemoved(ChannelHandlerContext var1) throws Exception;

    /** @deprecated */
    @Deprecated
    void exceptionCaught(ChannelHandlerContext var1, Throwable var2) throws Exception;

    @Inherited
    @Documented
    @Target({ElementType.TYPE})
    @Retention(RetentionPolicy.RUNTIME)
    public @interface Sharable {
    }
}