protected abstract class AbstractNioChannel.AbstractNioUnsafe extends AbstractChannel.AbstractUnsafe implements AbstractNioChannel.NioUnsafe
Modifier | Constructor and Description |
---|---|
protected |
AbstractNioUnsafe() |
Modifier and Type | Method and Description |
---|---|
void |
beginRead()
Schedules a read operation that fills the inbound buffer of the first
ChannelInboundHandler in the
ChannelPipeline . |
SelectableChannel |
ch()
Return underlying
SelectableChannel |
void |
connect(SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
|
void |
finishConnect()
Finish connect
|
protected void |
flush0() |
void |
forceFlush() |
protected void |
removeReadOp() |
bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, localAddress, outboundBuffer, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
read
bind, close, closeForcibly, deregister, disconnect, flush, localAddress, outboundBuffer, register, remoteAddress, voidPromise, write
protected final void removeReadOp()
public void beginRead()
Channel.Unsafe
ChannelInboundHandler
in the
ChannelPipeline
. If there's already a pending read operation, this method does nothing.beginRead
in interface Channel.Unsafe
beginRead
in class AbstractChannel.AbstractUnsafe
public SelectableChannel ch()
AbstractNioChannel.NioUnsafe
SelectableChannel
ch
in interface AbstractNioChannel.NioUnsafe
public void connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)
Channel.Unsafe
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.connect
in interface Channel.Unsafe
public void finishConnect()
AbstractNioChannel.NioUnsafe
finishConnect
in interface AbstractNioChannel.NioUnsafe
protected void flush0()
flush0
in class AbstractChannel.AbstractUnsafe
public void forceFlush()
forceFlush
in interface AbstractNioChannel.NioUnsafe
Copyright © 2008–2014 The Netty Project. All rights reserved.