public class Flusher extends Object
Constructor and Description |
---|
Flusher(Controller controller) |
Flusher(Controller controller,
int maxGather) |
Modifier and Type | Method and Description |
---|---|
Throwable |
append(StandardSession.DataFrameBytes frameBytes) |
Throwable |
append(StandardSession.FrameBytes frameBytes) |
void |
flush() |
int |
getQueueSize() |
Throwable |
prepend(StandardSession.FrameBytes frameBytes) |
void |
removeFrameBytesFromQueue(Stream stream) |
public Flusher(Controller controller)
public Flusher(Controller controller, int maxGather)
public void removeFrameBytesFromQueue(Stream stream)
public Throwable prepend(StandardSession.FrameBytes frameBytes)
public Throwable append(StandardSession.FrameBytes frameBytes)
public Throwable append(StandardSession.DataFrameBytes frameBytes)
public void flush()
public int getQueueSize()
Copyright © 1995-2015 Webtide. All Rights Reserved.