pub async fn split_read_stream(
            &mut self,
            request: impl tonic::IntoRequest<super::SplitReadStreamRequest>,
        ) -> Result<tonic::Response<super::SplitReadStreamResponse>, 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/SplitReadStream",
            );
            self.inner.unary(request.into_request(), path, codec).await
        }
/// Splits a given `ReadStream` into two `ReadStream` objects. These
/// `ReadStream` objects are referred to as the primary and the residual
/// streams of the split. The original `ReadStream` can still be read from in
/// the same manner as before. Both of the returned `ReadStream` objects can
/// also be read from, and the rows returned by both child streams will be
/// the same as the rows read from the original stream.
///
/// Moreover, the two child streams will be allocated back-to-back in the
/// original `ReadStream`. Concretely, it is guaranteed that for streams
/// original, primary, and residual, that original[0-j] = primary[0-j] and
/// original[j-n] = residual[0-m] once the streams have been read to
/// completion.
Splits a given `ReadStream` into two `ReadStream` objects. These
`ReadStream` objects are referred to as the primary and the residual
streams of the split. The original `ReadStream` can still be read from in
the same manner as before. Both of the returned `ReadStream` objects can
also be read from, and the rows returned by both child streams will be
the same as the rows read from the original stream.

Moreover, the two child streams will be allocated back-to-back in the
original `ReadStream`. Concretely, it is guaranteed that for streams
original, primary, and residual, that original[0-j] = primary[0-j] and
original[j-n] = residual[0-m] once the streams have been read to
completion.
Splits a given ` ReadStream ` into two ` ReadStream ` objects . These ` ReadStream ` objects are referred to as the primary and the residual streams of the split . The original ` ReadStream ` can still be read from in the same manner as before . Both of the returned ` ReadStream ` objects can also be read from and the rows returned by both child streams will be the same as the rows read from the original stream . Moreover the two child streams will be allocated back - to - back in the original ` ReadStream ` . Concretely it is guaranteed that for streams original primary and residual that original [ 0 - j ] = primary [ 0 - j ] and original [ j - n ] = residual [ 0 - m ] once the streams have been read to completion .
pub async fn split_read_stream(
            &mut self,
            request: impl tonic::IntoRequest<super::SplitReadStreamRequest>,
        ) -> Result<tonic::Response<super::SplitReadStreamResponse>, 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/SplitReadStream",
            );
            self.inner.unary(request.into_request(), path, codec).await
        }
pub async fn split_read_stream ( & mut self , request : impl tonic :: IntoRequest < super :: SplitReadStreamRequest > , ) -> Result < tonic :: Response < super :: SplitReadStreamResponse > , 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 . unary ( request . into_request ( ) , path , codec ) . await }
Splits a given `ReadStream` into two `ReadStream` objects.
Splits a given ` ReadStream ` into two ` ReadStream ` objects .
&mut self
request
impl tonic::IntoRequest<super::SplitReadStreamRequest>
&mut self
request
impl tonic::IntoRequest<super::SplitReadStreamRequest>