bigtable_rs::bigtable::read_rows

Function decode_read_rows_response_stream

source
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>)>>.