public interface SocketChannelWrapper extends Closeable
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Closes socket channel.
|
void |
closeInbound()
Closes inbound.
|
void |
closeOutbound()
Closes outbound.
|
SelectableChannel |
configureBlocking(boolean b) |
boolean |
connect(SocketAddress socketAddress) |
boolean |
isBlocking() |
boolean |
isConnected() |
boolean |
isOpen() |
SelectionKey |
keyFor(Selector selector) |
int |
read(ByteBuffer byteBuffer) |
SelectionKey |
register(Selector selector,
int ops,
Object attachment) |
Socket |
socket() |
int |
write(ByteBuffer byteBuffer) |
boolean isBlocking()
Socket socket()
boolean isConnected()
boolean connect(SocketAddress socketAddress) throws IOException
IOExceptionSelectionKey keyFor(Selector selector)
SelectionKey register(Selector selector, int ops, Object attachment) throws ClosedChannelException
ClosedChannelExceptionint read(ByteBuffer byteBuffer) throws IOException
IOExceptionint write(ByteBuffer byteBuffer) throws IOException
IOExceptionSelectableChannel configureBlocking(boolean b) throws IOException
IOExceptionboolean isOpen()
void closeInbound()
throws IOException
Not thread safe. Should be called in channel reader thread.
IOExceptionvoid closeOutbound()
throws IOException
Not thread safe. Should be called in channel writer thread.
IOExceptionvoid close()
throws IOException
close in interface AutoCloseableclose in interface CloseableIOExceptionCopyright © 2015 Hazelcast, Inc.. All Rights Reserved.