Package zmq.pipe

Class YPipeConflate<T extends Msg>

java.lang.Object
zmq.pipe.YPipeConflate<T>
All Implemented Interfaces:
YPipeBase<T>

public class YPipeConflate<T extends Msg> extends Object implements YPipeBase<T>
  • Field Details

    • readerAwake

      private boolean readerAwake
    • dbuffer

      private final DBuffer<T extends Msg> dbuffer
  • Constructor Details

    • YPipeConflate

      public YPipeConflate()
  • Method Details