Package zmq.pipe

Class YPipeConflate<T extends Msg>

  • All Implemented Interfaces:
    YPipeBase<T>

    public class YPipeConflate<T extends Msg>
    extends java.lang.Object
    implements YPipeBase<T>
    • Field Detail

      • readerAwake

        private boolean readerAwake
      • dbuffer

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

      • YPipeConflate

        public YPipeConflate()