pub fn stream<T>( settings: StreamSettings, ) -> Result<(StreamOutput<T, Error>, StreamInput<T>), Error>