Skip to main content

notification_reader_task

karyon_jsonrpc::client::http::h3

Function notification_reader_task 

Source 
pub(super) async fn notification_reader_task(
    recv: RequestStream<RecvStream, Bytes>,
    sub: Arc<Subscription>,
) -> Result<()>