Class XSub

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

public class XSub extends SocketBase
  • Field Details

    • fq

      private final FQ fq
    • dist

      private final Dist dist
    • subscriptions

      private final Trie subscriptions
    • hasMessage

      private boolean hasMessage
    • message

      private Msg message
    • more

      private boolean more
    • sendSubscription

      private final Trie.ITrieHandler sendSubscription
  • Constructor Details

    • XSub

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