Function driver_task 

async fn driver_task<T>(conn: Connection<T, Full<Bytes>>)
where
    T: Read + Write + Unpin + Send + 'static,