[−][src]Struct grpc::ClientRequestSink
And interface to send messages when client request is streaming.
Methods
impl<Req: Send> ClientRequestSink<Req>[src]
pub fn poll(&mut self, cx: &mut Context) -> Poll<Result<(), StreamDead>>[src]
Poll for write availability.
When request is not polled, send_data
will be successful anyway, but client memory can overflow.
pub fn wait<'a>(
&'a mut self
) -> impl Future<Output = Result<(), StreamDead>> + 'a[src]
&'a mut self
) -> impl Future<Output = Result<(), StreamDead>> + 'a
Wait for buffer availability.
When request is not polled, send_data
will be successful anyway, but client memory can overflow.
pub fn send_data(&mut self, message: Req) -> Result<()>[src]
Send a message.
pub fn finish(&mut self) -> Result<()>[src]
Finish client request.
This is mandatory operation, if it is not called, client will reset the stream on drop.
Auto Trait Implementations
impl<Req> !RefUnwindSafe for ClientRequestSink<Req>
impl<Req> Send for ClientRequestSink<Req>
impl<Req> !Sync for ClientRequestSink<Req>
impl<Req> Unpin for ClientRequestSink<Req>
impl<Req> !UnwindSafe for ClientRequestSink<Req>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,