run

jetstream::prelude::server

Function run 

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