pub async fn create_write_stream(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateWriteStreamRequest>,
        ) -> Result<tonic::Response<super::WriteStream>, 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.BigQueryWrite/CreateWriteStream",
            );
            self.inner.unary(request.into_request(), path, codec).await
        }
/// Creates a write stream to the given table.
/// Additionally, every table has a special stream named '_default'
/// to which data can be written. This stream doesn't need to be created using
/// CreateWriteStream. It is a stream that can be used simultaneously by any
/// number of clients. Data written to this stream is considered committed as
/// soon as an acknowledgement is received.
Creates a write stream to the given table.
Additionally, every table has a special stream named '_default'
to which data can be written. This stream doesn't need to be created using
CreateWriteStream. It is a stream that can be used simultaneously by any
number of clients. Data written to this stream is considered committed as
soon as an acknowledgement is received.
Creates a write stream to the given table . Additionally every table has a special stream named ' _default ' to which data can be written . This stream doesn ' t need to be created using CreateWriteStream . It is a stream that can be used simultaneously by any number of clients . Data written to this stream is considered committed as soon as an acknowledgement is received .
pub async fn create_write_stream(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateWriteStreamRequest>,
        ) -> Result<tonic::Response<super::WriteStream>, 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.BigQueryWrite/CreateWriteStream",
            );
            self.inner.unary(request.into_request(), path, codec).await
        }
pub async fn create_write_stream ( & mut self , request : impl tonic :: IntoRequest < super :: CreateWriteStreamRequest > , ) -> Result < tonic :: Response < super :: WriteStream > , 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 }
Creates a write stream to the given table.
Creates a write stream to the given table .
&mut self
request
impl tonic::IntoRequest<super::CreateWriteStreamRequest>
&mut self
request
impl tonic::IntoRequest<super::CreateWriteStreamRequest>