pub fn into_streaming_request( rows: Vec<AppendRowsRequest>, ) -> impl Stream<Item = AppendRowsRequest>