Skip to main content

dispatch_subs_task

karyon_jsonrpc::server::http::h3

Function dispatch_subs_task 

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