Class LocalChannel.LocalUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.local.LocalChannel.LocalUnsafe

All Implemented Interfaces:

Channel.Unsafe, IoHandle, LocalIoHandle, AutoCloseable

Enclosing class:

LocalChannel

private class LocalChannel.LocalUnsafe
extends AbstractChannel.AbstractUnsafe
implements LocalIoHandle

Field Summary

Fields

Modifier and Type	Field	Description
private final Runnable	shutdownHook

Constructor Summary

Constructors

Modifier	Constructor	Description
private	LocalUnsafe()

Method Summary

Modifier and Type	Method	Description
void	close()	Called once the IoHandle should be closed.
void	closeNow()
void	connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)	Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
void	handle(IoRegistration registration, IoEvent event)	Be called once there is something to handle.
void	registered()	Called once this IoHandle was registered and so will start to receive events via IoHandle.handle(IoRegistration, IoEvent).
void	unregistered()	Called once this IoHandle was unregistered and so will not receive any more events via IoHandle.handle(IoRegistration, IoEvent).

Methods inherited from class AbstractChannel.AbstractUnsafe

annotateConnectException, beginRead, bind, close, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, flush0, handleWriteError, localAddress, outboundBuffer, prepareToClose, recvBufAllocHandle, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write

Methods inherited from class Object

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

Field Details

shutdownHook

private final Runnable shutdownHook

Constructor Details

LocalUnsafe

private LocalUnsafe()

Method Details

close

public void close()

Description copied from interface: IoHandle

Called once the IoHandle should be closed. Even once this method is called this handle might still receive events via IoHandle.handle(IoRegistration, IoEvent) (if it was previous be registered and so its IoHandle.registered() method was called) until the IoHandle.unregistered() method is called.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface IoHandle

handle

public void handle(IoRegistration registration,
 IoEvent event)

Description copied from interface: IoHandle

Be called once there is something to handle.

Specified by:

handle in interface IoHandle

Parameters:

registration - the IoRegistration for this IoHandle.

event - the IoEvent that must be handled. The IoEvent is only valid while this method is executed and so must not escape it.

registered

public void registered()

Description copied from interface: IoHandle

Called once this IoHandle was registered and so will start to receive events via IoHandle.handle(IoRegistration, IoEvent).

Specified by:

registered in interface IoHandle

unregistered

public void unregistered()

Description copied from interface: IoHandle

Called once this IoHandle was unregistered and so will not receive any more events via IoHandle.handle(IoRegistration, IoEvent).

Specified by:

unregistered in interface IoHandle

closeNow

public void closeNow()

Specified by:

closeNow in interface LocalIoHandle

connect

public void connect(SocketAddress remoteAddress,
 SocketAddress localAddress,
 ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Connect the Channel of the given ChannelFuture with the given remote SocketAddress. If a specific local SocketAddress should be used it need to be given as argument. Otherwise just pass null to it. The ChannelPromise will get notified once the connect operation was complete.

Specified by:

connect in interface Channel.Unsafe