Function run 

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