public abstract class TNonblockingTransport extends TTransport
Constructor and Description |
---|
TNonblockingTransport() |
Modifier and Type | Method and Description |
---|---|
abstract boolean |
finishConnect()
Non-blocking connection completion.
|
abstract int |
read(java.nio.ByteBuffer buffer) |
abstract java.nio.channels.SelectionKey |
registerSelector(java.nio.channels.Selector selector,
int interests) |
abstract boolean |
startConnect()
Non-blocking connection initialization.
|
abstract int |
write(java.nio.ByteBuffer buffer) |
close, consumeBuffer, flush, getBuffer, getBufferPosition, getBytesRemainingInBuffer, isOpen, open, peek, read, readAll, write, write
public abstract boolean startConnect() throws java.io.IOException
java.io.IOException
SocketChannel.connect(SocketAddress remote)
public abstract boolean finishConnect() throws java.io.IOException
java.io.IOException
SocketChannel.finishConnect()
public abstract java.nio.channels.SelectionKey registerSelector(java.nio.channels.Selector selector, int interests) throws java.io.IOException
java.io.IOException
public abstract int read(java.nio.ByteBuffer buffer) throws java.io.IOException
java.io.IOException
public abstract int write(java.nio.ByteBuffer buffer) throws java.io.IOException
java.io.IOException