MCPcopy Create free account
hub / github.com/3rdparty/libprocess / Consumer

Class Consumer

src/event_queue.hpp:89–105  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

87 } producer;
88
89 class Consumer
90 {
91 public:
92 Event* dequeue() { return queue->dequeue(); }
93 bool empty() { return queue->empty(); }
94 void decomission() { queue->decomission(); }
95 template <typename T>
96 size_t count() { return queue->count<T>(); }
97 operator JSON::Array() { return queue->operator JSON::Array(); }
98
99 private:
100 friend class EventQueue;
101
102 Consumer(EventQueue* queue) : queue(queue) {}
103
104 EventQueue* queue;
105 } consumer;
106
107private:
108 friend class Producer;

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected