Struct ClientRequestSink 

pub struct ClientRequestSink<Req: Send + 'static> { /* private fields */ }

And interface to send messages when client request is streaming.

Implementations

impl<Req: Send> ClientRequestSink<Req>

pub fn poll(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), StreamDead>>

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

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<()>

Send a message.

pub fn finish(&mut self) -> Result<()>

Finish client request.

This is mandatory operation, if it is not called, client will reset the stream on drop.