public class Flusher
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
private class |
Flusher.FlushCallback |
private class |
Flusher.ShutdownResult |
Modifier and Type | Field and Description |
---|---|
private EndPoint |
endPoint |
private IteratingCallback |
flushCallback |
private static Logger |
LOG |
private java.util.Queue<Generator.Result> |
queue |
Modifier and Type | Method and Description |
---|---|
void |
flush(Generator.Result... results) |
private void |
offer(Generator.Result result) |
private Generator.Result |
poll() |
void |
shutdown() |
private static final Logger LOG
private final java.util.Queue<Generator.Result> queue
private final IteratingCallback flushCallback
private final EndPoint endPoint
public Flusher(EndPoint endPoint)
public void flush(Generator.Result... results)
private void offer(Generator.Result result)
private Generator.Result poll()
public void shutdown()