public class YPipeConflate<T extends Msg> extends java.lang.Object implements YPipeBase<T>
private DBuffer<T>
dbuffer
private boolean
readerAwake
YPipeConflate()
boolean
checkRead()
flush()
T
probe()
read()
unwrite()
void
write(T value, boolean incomplete)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
private boolean readerAwake
private final DBuffer<T extends Msg> dbuffer
public YPipeConflate()
public void write(T value, boolean incomplete)
write
YPipeBase<T extends Msg>
public T unwrite()
unwrite
public boolean flush()
flush
public boolean checkRead()
checkRead
public T read()
read
public T probe()
probe