Function run 

pub async fn run<T: Transport + Send, P: Processor<T>>(
    transport: T,
    processor: P,
) -> Result<(), RunError<T::Error, P::Error>>