protected void
processHiccup(YPipeBase<Msg> hiccupPipe)
protected final void
sendHiccup(Pipe destination, YPipeBase<Msg> pipe)
class
YPipe<T>
YPipeConflate<T extends Msg>
private YPipeBase<Msg>
inpipe
outpipe
processHiccup(YPipeBase<Msg> pipe)
private
Pipe(ZObject parent, YPipeBase<Msg> inpipe, YPipeBase<Msg> outpipe, int inhwm, int outhwm, boolean conflate)