Skip to main content

run

jetstream::prelude::server

Function run 

Source 
pub async fn run<T, P>(
    p: &mut P,
    transport: T,
) -> Result<(), <P as Protocol>::Error>
where
    T: ServiceTransport<P>,
    P: Server,
    <P as Protocol>::Response: 'static,
    <P as Protocol>::Error: 'static,