pub struct DefaultStream { /* private fields */ }Implementations§
Source§impl DefaultStream
impl DefaultStream
pub async fn append_rows( &self, rows: Vec<AppendRowsRequestBuilder>, ) -> Result<Streaming<AppendRowsResponse>, Status>
Trait Implementations§
Source§impl AsStream for DefaultStream
impl AsStream for DefaultStream
fn as_ref(&self) -> &Stream
fn name(&self) -> &str
fn create_streaming_request( &self, rows: Vec<AppendRowsRequestBuilder>, ) -> impl Stream<Item = AppendRowsRequest>
Auto Trait Implementations§
impl !Freeze for DefaultStream
impl !RefUnwindSafe for DefaultStream
impl Send for DefaultStream
impl Sync for DefaultStream
impl Unpin for DefaultStream
impl UnsafeUnpin for DefaultStream
impl !UnwindSafe for DefaultStream
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request