| 992 | } |
| 993 | |
| 994 | void Consumer::CustomGetRequest(const comm::proto::ConsumerContext &cc, |
| 995 | const comm::proto::GetRequest &req, |
| 996 | uint64_t &pre_cursor_id, uint64_t &next_cursor_id, int &limit) { |
| 997 | pre_cursor_id = req.next_cursor_id(); |
| 998 | } |
| 999 | |
| 1000 | void Consumer::AfterConsume(const comm::proto::ConsumerContext &cc, |
| 1001 | const std::vector<std::shared_ptr<comm::proto::QItem> > &items, |
nothing calls this directly
no outgoing calls
no test coverage detected