Class ConsumeCtx_t

phxqueue/consumer/consumer.cpp:50–54

};

struct ConsumeCtx_t {
    stCoRoutine_t *co = nullptr;
    int cid = -1;
    Consumer *consumer = nullptr;
};

class Consumer::ConsumerImpl {
  public: