Interface AbstractNioChannel.NioUnsafe

All Superinterfaces:

Channel.Unsafe

All Known Implementing Classes:

AbstractNioByteChannel.NioByteUnsafe, AbstractNioChannel.AbstractNioUnsafe

Enclosing class:

AbstractNioChannel

public static interface AbstractNioChannel.NioUnsafe
extends Channel.Unsafe

Special Channel.Unsafe sub-type which allows to access the underlying SelectableChannel

Method Summary

Modifier and Type	Method	Description
SelectableChannel	ch()	Return underlying SelectableChannel
void	finishConnect()	Finish connect
void	forceFlush()
void	read()	Read from underlying SelectableChannel

Methods inherited from interface Channel.Unsafe

beginRead, bind, close, closeForcibly, connect, deregister, disconnect, flush, localAddress, outboundBuffer, recvBufAllocHandle, register, remoteAddress, voidPromise, write

Modifier and Type	Method	Description
void	beginRead()	Schedules a read operation that fills the inbound buffer of the first ChannelInboundHandler in the ChannelPipeline.
void	bind(SocketAddress localAddress, ChannelPromise promise)	Bind the SocketAddress to the Channel of the ChannelPromise and notify it once its done.
void	close(ChannelPromise promise)	Close the Channel of the ChannelPromise and notify the ChannelPromise once the operation was complete.
void	closeForcibly()	Closes the Channel immediately without firing any events.
void	connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)	Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
void	deregister(ChannelPromise promise)	Deregister the Channel of the ChannelPromise from EventLoop and notify the ChannelPromise once the operation was complete.
void	disconnect(ChannelPromise promise)	Disconnect the Channel of the ChannelFuture and notify the ChannelPromise once the operation was complete.
void	flush()	Flush out all write operations scheduled via Channel.Unsafe.write(Object, ChannelPromise).
SocketAddress	localAddress()	Return the SocketAddress to which is bound local or null if none.
ChannelOutboundBuffer	outboundBuffer()	Returns the ChannelOutboundBuffer of the Channel where the pending write requests are stored.
RecvByteBufAllocator.Handle	recvBufAllocHandle()	Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.
void	register(EventLoop eventLoop, ChannelPromise promise)	Register the Channel of the ChannelPromise and notify the ChannelFuture once the registration was complete.
SocketAddress	remoteAddress()	Return the SocketAddress to which is bound remote or null if none is bound yet.
ChannelPromise	voidPromise()	Return a special ChannelPromise which can be reused and passed to the operations in Channel.Unsafe.
void	write(Object msg, ChannelPromise promise)	Schedules a write operation.

Method Details

ch

SelectableChannel ch()

Return underlying SelectableChannel

finishConnect

void finishConnect()

Finish connect

read

void read()

Read from underlying SelectableChannel

forceFlush

void forceFlush()