pub async fn decode_read_rows_response_stream(
rrr: Streaming<ReadRowsResponse>,
) -> impl Stream<Item = Result<(Vec<u8>, Vec<RowCell>), Error>>
Expand description
Flatten and decode the stream of ReadRowsResponse
into a stream of Result<(RowKey, Vec<RowCell>)>>
.