/// Reads rows from the stream in the format prescribed by the ReadSession.
/// Each response contains one or more table rows, up to a maximum of 100 MiB
/// per response; read requests which attempt to read individual rows larger
/// than 100 MiB will fail.
///
/// Each request also returns a set of stream statistics reflecting the current
/// state of the stream.
Reads rows from the stream in the format prescribed by the ReadSession.
Each response contains one or more table rows, up to a maximum of 100 MiB
per response; read requests which attempt to read individual rows larger
than 100 MiB will fail.

Each request also returns a set of stream statistics reflecting the current
state of the stream.
Reads rows from the stream in the format prescribed by the ReadSession . Each response contains one or more table rows up to a maximum of 100 MiB per response ; read requests which attempt to read individual rows larger than 100 MiB will fail . Each request also returns a set of stream statistics reflecting the current state of the stream .
pub async fn read_rows(
            &mut self,
            request: impl tonic::IntoRequest<super::ReadRowsRequest>,
        ) -> Result<
            tonic::Response<tonic::codec::Streaming<super::ReadRowsResponse>>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/google.cloud.bigquery.storage.v1.BigQueryRead/ReadRows",
            );
            self.inner.server_streaming(request.into_request(), path, codec).await
        }
pub async fn read_rows ( & mut self , request : impl tonic :: IntoRequest < super :: ReadRowsRequest > , ) -> Result < tonic :: Response < tonic :: codec :: Streaming < super :: ReadRowsResponse > > , tonic :: Status , > { self . inner . ready ( ) . await . map_err ( | e | { tonic :: Status :: new ( tonic :: Code :: Unknown , format ! ( " " e into ( ) ) , ) } ) ? ; let codec = tonic :: codec :: ProstCodec :: default ( ) ; let path = http :: uri :: PathAndQuery :: from_static ( " " , ) ; self . inner . server_streaming ( request . into_request ( ) , path , codec ) . await }
Reads rows from the stream in the format prescribed by the ReadSession.
Reads rows from the stream in the format prescribed by the ReadSession .
&mut self
request
impl tonic::IntoRequest<super::ReadRowsRequest>