26 explicit ConflatedEventChannel(std::string name, OnRemoveCallback on_listener_removal = {});
27 ~ConflatedEventChannel() override;
30 template <
typename... Args>
37 template <
typename Class>
43 template <
typename... Args>
44 void OnChannelEvent(Args...);
46 std::atomic<
bool> stop_flag_;
48 std::vector<
concurrent::AsyncEventSubscriberScope> subscriptions_;
49 engine::SingleConsumerEvent event_;