public class SocketChannelHandler extends Object implements ChannelHandler
Constructor and Description |
---|
SocketChannelHandler(SocketChannel channel,
BorrowedBuffer<ByteBuffer> inboundBuffer,
BorrowedBuffer<ByteBuffer> outboundBuffer,
Function<ChannelHandler,ChannelHandlerContext> contextFactory,
DataReceiver dataReceiver) |
Modifier and Type | Method and Description |
---|---|
void |
activate() |
void |
close()
Request to close.
|
void |
deactivate() |
void |
flush()
Request to write pending outgoing data to the underlying channel.
|
boolean |
isClosed() |
boolean |
read()
Request to read incoming data from the underlying channel.
|
Message |
receive() |
void |
register() |
void |
send(Message message) |
void |
unregister() |
public SocketChannelHandler(SocketChannel channel, BorrowedBuffer<ByteBuffer> inboundBuffer, BorrowedBuffer<ByteBuffer> outboundBuffer, Function<ChannelHandler,ChannelHandlerContext> contextFactory, DataReceiver dataReceiver)
public void send(Message message)
send
in interface ChannelHandler
public Message receive()
receive
in interface ChannelHandler
public boolean read() throws IOException
ChannelHandler
read
in interface ChannelHandler
IOException
public void register()
register
in interface ChannelHandler
public void unregister()
unregister
in interface ChannelHandler
public void activate()
activate
in interface ChannelHandler
public void deactivate()
deactivate
in interface ChannelHandler
public void flush()
ChannelHandler
flush
in interface ChannelHandler
public void close()
ChannelHandler
close
in interface ChannelHandler
public boolean isClosed()
isClosed
in interface ChannelHandler
Copyright © 2016–2021. All rights reserved.