Skip to main content

handle_quic_subscription

Function handle_quic_subscription 

Source
async fn handle_quic_subscription(
    server: Arc<Server>,
    conn: FramedConn<JsonCodec>,
    req: NewRequest,
) -> Result<()>
Expand description

Pubsub over QUIC: split the stream so notifications stream from the writer while the reader waits for an unsubscribe.