pub(super) async fn subscribe(
send_request: SendRequest<OpenStreams, Bytes>,
msg: Value,
) -> Result<(Response, RequestStream<RecvStream, Bytes>)>Expand description
Subscribe over HTTP/3: send the request, read the initial response, and return the recv half for streaming notifications.