Package zmq.pipe

Class YPipe<T>

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

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

    • queue

      private final YQueue<T> queue
    • w

      private int w
    • r

      private int r
    • f

      private int f
    • c

      private final AtomicInteger c
  • Constructor Details

    • YPipe

      public YPipe(int qsize)
  • Method Details

    • write

      public void write(T value, boolean incomplete)
      Specified by:
      write in interface YPipeBase<T>
    • unwrite

      public T unwrite()
      Specified by:
      unwrite in interface YPipeBase<T>
    • flush

      public boolean flush()
      Specified by:
      flush in interface YPipeBase<T>
    • checkRead

      public boolean checkRead()
      Specified by:
      checkRead in interface YPipeBase<T>
    • read

      public T read()
      Specified by:
      read in interface YPipeBase<T>
    • probe

      public T probe()
      Specified by:
      probe in interface YPipeBase<T>