pub(super) fn start_flow_notification_worker(
receiver: Receiver<FlowNotification>,
cache: TableFlownodeSetCacheRef,
node_manager: NodeManagerRef,
)Expand description
Composes queue consumption and delivery without giving the notifier task ownership.