cancel_all distributor distributor drop publish queue reject_all reject_all subscribe

queue template<typename T , typename Lock = nolock> template<typename QueueImpl = typename queue<T>::behavior> using coro::distributor< T, Lock >::queue = distributor_queue<T, Lock, QueueImpl> Implements queue above distributor. Template Parameters Filter specifies filter function. Filter function is called synchronously for the every item. It should return true to push item into queue, or false to discard the item. This can help with slow subscribers to control the queue size. For example, the function can skip unimportant events QueueImpl internal queue implementation You need to connect the object to a distributor Definition at line 159 of file distributor.h.