Function rafka::transport::new

pub async fn new<T>(io: T) -> TypedClient<T> where
    T: AsyncRead + AsyncWrite + Send + 'static,