Skip to main content

handle_h3_subscription

karyon_jsonrpc::server::http::h3

Function handle_h3_subscription 

Source 
async fn handle_h3_subscription<C: JsonRpcCodec>(
    server: Arc<Server>,
    req: NewRequest,
    send: RequestStream<SendStream<Bytes>, Bytes>,
    reader: BodyReader<C>,
    peer: Option<Endpoint>,
    codec: C,
) -> Result<()>
Expand description

Pubsub over HTTP/3: the subscription gets its own Channel. Notifications stream on the response while the request body waits for the unsubscribe request.