mz_service::transport

Function serve_connection

Source 
async fn serve_connection<In, Out, H>(
    stream: Stream,
    handler: H,
    version: Version,
    server_fqdn: Option<String>,
    timeout: Duration,
    cancel_rx: Receiver<()>,
    metrics: impl Metrics<Out, In>,
) -> Result<Infallible>
where
    In: Message,
    Out: Message,
    H: GenericClient<In, Out>,
Expand description

Serve a single CTP connection.