Skip to main content

drain_publish_queue

hypercall_api::notification_service

Function drain_publish_queue 

Source 
async fn drain_publish_queue(
    svc: Arc<NotificationService>,
    rx: Receiver<PublishJob>,
    shutdown_rx: Receiver<()>,
)