Class XPub

All Implemented Interfaces:
Pipe.IPipeEvents, IPollEvents
Direct Known Subclasses:
Pub

public class XPub extends SocketBase
  • Field Details

    • subscriptions

      private final Mtrie subscriptions
    • manualSubscriptions

      private final Mtrie manualSubscriptions
    • dist

      private final Dist dist
    • verboseSubs

      private boolean verboseSubs
    • verboseUnsubs

      private boolean verboseUnsubs
    • more

      private boolean more
    • lossy

      private boolean lossy
    • manual

      private boolean manual
    • lastPipe

      private Pipe lastPipe
    • pendingPipes

      private final Deque<Pipe> pendingPipes
    • pendingData

      private final Deque<Blob> pendingData
    • pendingFlags

      private final Deque<Integer> pendingFlags
    • markAsMatching

      private static final Mtrie.IMtrieHandler markAsMatching
    • sendUnsubscription

      private static final Mtrie.IMtrieHandler sendUnsubscription
  • Constructor Details

    • XPub

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