cancel_all distributor distributor drop publish queue reject_all reject_all subscribe

cancel_all() template<typename T , typename Lock = nolock> void coro::distributor< T, Lock >::cancel_all ( ) inline drops all subscribers Subscribers are removed by receiving broken_promise. This allows to broadcast "end of stream" Definition at line 86 of file distributor.h. Here is the caller graph for this function: