jetstream_server::service

Function run

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