Class Dish

All Implemented Interfaces:
Pipe.IPipeEvents, IPollEvents

public class Dish extends SocketBase
  • Field Details

    • fq

      private final FQ fq
    • dist

      private final Dist dist
    • subscriptions

      private final Set<String> subscriptions
    • pendingMsg

      private Msg pendingMsg
  • Constructor Details

    • Dish

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