Package zmq.socket

Class Stream

All Implemented Interfaces:
Pipe.IPipeEvents, IPollEvents

public class Stream extends SocketBase
  • Field Details

    • fq

      private final FQ fq
    • prefetched

      private boolean prefetched
    • identitySent

      private boolean identitySent
    • prefetchedId

      private Msg prefetchedId
    • prefetchedMsg

      private Msg prefetchedMsg
    • outpipes

      private Map<Blob,Stream.Outpipe> outpipes
    • currentOut

      private Pipe currentOut
    • moreOut

      private boolean moreOut
    • nextRid

      private int nextRid
  • Constructor Details

    • Stream

      public Stream(Ctx parent, int tid, int sid)
  • Method Details