final class RemoteConnection.RemoteWriteListener
extends java.lang.Object
implements org.xnio.ChannelListener<org.xnio.channels.ConnectedMessageChannel>
| Modifier and Type | Field and Description |
|---|---|
private boolean |
closed |
private org.xnio.XnioExecutor.Key |
heartKey |
private java.util.Queue<org.xnio.Pooled<java.nio.ByteBuffer>> |
queue |
| Constructor and Description |
|---|
RemoteWriteListener() |
| Modifier and Type | Method and Description |
|---|---|
void |
handleEvent(org.xnio.channels.ConnectedMessageChannel channel) |
void |
send(org.xnio.Pooled<java.nio.ByteBuffer> pooled,
boolean close) |
void |
shutdownWrites() |
private final java.util.Queue<org.xnio.Pooled<java.nio.ByteBuffer>> queue
private org.xnio.XnioExecutor.Key heartKey
private boolean closed
public void handleEvent(org.xnio.channels.ConnectedMessageChannel channel)
handleEvent in interface org.xnio.ChannelListener<org.xnio.channels.ConnectedMessageChannel>public void shutdownWrites()
public void send(org.xnio.Pooled<java.nio.ByteBuffer> pooled,
boolean close)