Function stream 

pub fn stream<E>(
    endpoint: &RemoteEndpoint,
    command: &RemoteCommand,
    token: &CancelToken,
    consume: impl FnMut(&[u8]) -> Result<(), E>,
) -> Result<RemoteStreamOutput, RemoteStreamError<E>>