Skip to main content

dispatch_subs_task

Function dispatch_subs_task 

Source
async fn dispatch_subs_task(
    ch_rx: Receiver<NewNotification>,
    sub_senders: Arc<RwLock<HashMap<SubscriptionID, Sender<NewNotification>>>>,
) -> Result<()>