jetstream::prelude::server::service

Function run

pub async fn run<T, P>(
    p: &mut P,
    stream: T,
) -> Result<(), <P as Protocol>::Error>where
    T: ServiceTransport<P>,
    P: Protocol,