public class FrameFlusher extends Object
EndPoint.write(Callback, ByteBuffer...)
Modifier and Type | Field and Description |
---|---|
static BinaryFrame |
FLUSH_FRAME |
Constructor and Description |
---|
FrameFlusher(ByteBufferPool bufferPool,
Generator generator,
EndPoint endpoint,
int bufferSize,
int maxGather) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
enqueue(Frame frame,
WriteCallback callback,
BatchMode batchMode) |
protected void |
notifyCallbackFailure(WriteCallback callback,
Throwable failure) |
protected void |
notifyCallbackSuccess(WriteCallback callback) |
protected void |
onFailure(Throwable x) |
String |
toString() |
public static final BinaryFrame FLUSH_FRAME
public FrameFlusher(ByteBufferPool bufferPool, Generator generator, EndPoint endpoint, int bufferSize, int maxGather)
public void close()
public void enqueue(Frame frame, WriteCallback callback, BatchMode batchMode)
protected void notifyCallbackFailure(WriteCallback callback, Throwable failure)
protected void notifyCallbackSuccess(WriteCallback callback)
protected void onFailure(Throwable x)
Copyright © 1995-2015 Webtide. All Rights Reserved.