io.netty.channel

Class ChannelHandlerInvokerUtil

java.lang.Object

io.netty.channel.ChannelHandlerInvokerUtil

public final class ChannelHandlerInvokerUtil
extends Object

A set of helper methods for easier implementation of custom ChannelHandlerInvoker implementation.

Method Summary

Methods

Modifier and Type	Method and Description
static void	invokeBindNow(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise)
static void	invokeChannelActiveNow(ChannelHandlerContext ctx)
static void	invokeChannelInactiveNow(ChannelHandlerContext ctx)
static void	invokeChannelReadCompleteNow(ChannelHandlerContext ctx)
static void	invokeChannelReadNow(ChannelHandlerContext ctx, Object msg)
static void	invokeChannelRegisteredNow(ChannelHandlerContext ctx)
static void	invokeChannelUnregisteredNow(ChannelHandlerContext ctx)
static void	invokeChannelWritabilityChangedNow(ChannelHandlerContext ctx)
static void	invokeCloseNow(ChannelHandlerContext ctx, ChannelPromise promise)
static void	invokeConnectNow(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)
static void	invokeDeregisterNow(ChannelHandlerContext ctx, ChannelPromise promise)
static void	invokeDisconnectNow(ChannelHandlerContext ctx, ChannelPromise promise)
static void	invokeExceptionCaughtNow(ChannelHandlerContext ctx, Throwable cause)
static void	invokeFlushNow(ChannelHandlerContext ctx)
static void	invokeReadNow(ChannelHandlerContext ctx)
static void	invokeUserEventTriggeredNow(ChannelHandlerContext ctx, Object event)
static void	invokeWriteNow(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
static boolean	validatePromise(ChannelHandlerContext ctx, ChannelPromise promise, boolean allowVoidPromise)

Methods inherited from class java.lang.Object

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

Method Detail

invokeChannelRegisteredNow

public static void invokeChannelRegisteredNow(ChannelHandlerContext ctx)

invokeChannelUnregisteredNow

public static void invokeChannelUnregisteredNow(ChannelHandlerContext ctx)

invokeChannelActiveNow

public static void invokeChannelActiveNow(ChannelHandlerContext ctx)

invokeChannelInactiveNow

public static void invokeChannelInactiveNow(ChannelHandlerContext ctx)

invokeExceptionCaughtNow

public static void invokeExceptionCaughtNow(ChannelHandlerContext ctx,
                            Throwable cause)

invokeUserEventTriggeredNow

public static void invokeUserEventTriggeredNow(ChannelHandlerContext ctx,
                               Object event)

invokeChannelReadNow

public static void invokeChannelReadNow(ChannelHandlerContext ctx,
                        Object msg)

invokeChannelReadCompleteNow

public static void invokeChannelReadCompleteNow(ChannelHandlerContext ctx)

invokeChannelWritabilityChangedNow

public static void invokeChannelWritabilityChangedNow(ChannelHandlerContext ctx)

invokeBindNow

public static void invokeBindNow(ChannelHandlerContext ctx,
                 SocketAddress localAddress,
                 ChannelPromise promise)

invokeConnectNow

public static void invokeConnectNow(ChannelHandlerContext ctx,
                    SocketAddress remoteAddress,
                    SocketAddress localAddress,
                    ChannelPromise promise)

invokeDisconnectNow

public static void invokeDisconnectNow(ChannelHandlerContext ctx,
                       ChannelPromise promise)

invokeCloseNow

public static void invokeCloseNow(ChannelHandlerContext ctx,
                  ChannelPromise promise)

invokeDeregisterNow

public static void invokeDeregisterNow(ChannelHandlerContext ctx,
                       ChannelPromise promise)

invokeReadNow

public static void invokeReadNow(ChannelHandlerContext ctx)

invokeWriteNow

public static void invokeWriteNow(ChannelHandlerContext ctx,
                  Object msg,
                  ChannelPromise promise)

invokeFlushNow

public static void invokeFlushNow(ChannelHandlerContext ctx)

validatePromise

public static boolean validatePromise(ChannelHandlerContext ctx,
                      ChannelPromise promise,
                      boolean allowVoidPromise)