Package io.netty.channel.nio
Class AbstractNioChannel.AbstractNioUnsafe
- java.lang.Object
-
- io.netty.channel.AbstractChannel.AbstractUnsafe
-
- io.netty.channel.nio.AbstractNioChannel.AbstractNioUnsafe
-
- All Implemented Interfaces:
Channel.Unsafe
,AbstractNioChannel.NioUnsafe
- Direct Known Subclasses:
AbstractNioByteChannel.NioByteUnsafe
- Enclosing class:
- AbstractNioChannel
protected abstract class AbstractNioChannel.AbstractNioUnsafe extends AbstractChannel.AbstractUnsafe implements AbstractNioChannel.NioUnsafe
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractNioUnsafe()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SelectableChannel
ch()
Return underlyingSelectableChannel
void
connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)
void
finishConnect()
Finish connectprotected void
flush0()
void
forceFlush()
protected void
removeReadOp()
-
Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, handleWriteError, localAddress, outboundBuffer, prepareToClose, recvBufAllocHandle, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.netty.channel.nio.AbstractNioChannel.NioUnsafe
read
-
Methods inherited from interface io.netty.channel.Channel.Unsafe
beginRead, bind, close, closeForcibly, deregister, disconnect, flush, localAddress, outboundBuffer, recvBufAllocHandle, register, remoteAddress, voidPromise, write
-
-
-
-
Method Detail
-
removeReadOp
protected final void removeReadOp()
-
ch
public final SelectableChannel ch()
Description copied from interface:AbstractNioChannel.NioUnsafe
Return underlyingSelectableChannel
- Specified by:
ch
in interfaceAbstractNioChannel.NioUnsafe
-
connect
public final void connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)
Description copied from interface:Channel.Unsafe
Connect theChannel
of the givenChannelFuture
with the given remoteSocketAddress
. If a specific localSocketAddress
should be used it need to be given as argument. Otherwise just passnull
to it. TheChannelPromise
will get notified once the connect operation was complete.- Specified by:
connect
in interfaceChannel.Unsafe
-
finishConnect
public final void finishConnect()
Description copied from interface:AbstractNioChannel.NioUnsafe
Finish connect- Specified by:
finishConnect
in interfaceAbstractNioChannel.NioUnsafe
-
flush0
protected final void flush0()
- Overrides:
flush0
in classAbstractChannel.AbstractUnsafe
-
forceFlush
public final void forceFlush()
- Specified by:
forceFlush
in interfaceAbstractNioChannel.NioUnsafe
-
-