Skip to main content

handle_h3_subscribe

Function handle_h3_subscribe 

Source
async fn handle_h3_subscribe(
    server: Arc<Server>,
    sub_senders: Arc<RwLock<HashMap<SubscriptionID, Sender<NewNotification>>>>,
    msg: Value,
    stream: RequestStream<BidiStream<Bytes>, Bytes>,
) -> Result<()>
Expand description

Subscribe: respond, then stream notifications on the same stream.