// libtibrv doesn't provide an explicit "async send" routine
// From the documentation it looks like tibrvTransport_Send
// isn't supposed to block, so we have to just assume it's
// doing internal buffering.
libtibrv doesn't provide an explicit "async send" routine
From the documentation it looks like tibrvTransport_Send
isn't supposed to block, so we have to just assume it's
doing internal buffering.
libtibrv doesn ' t provide an explicit " async send " routine From the documentation it looks like tibrvTransport_Send isn ' t supposed to block so we have to just assume it ' s doing internal buffering .
fn start_send(
        &mut self,
        mut item: Msg,
    ) -> StartSend<Self::SinkItem, Self::SinkError> {
        // Here we do the send immediately, then always return
        // complete when poll_complete is called later.
        Transport::send(self, &mut item)?;
        Ok(AsyncSink::Ready)
    }
fn start_send ( & mut self , mut item : Msg , ) -> StartSend < Self :: SinkItem , Self :: SinkError > { // Here we do the send immediately, then always return // complete when poll_complete is called later. Transport :: send ( self , & mut item ) ? ; Ok ( AsyncSink :: Ready ) }
libtibrv doesn't provide an explicit "async send" routine
From the documentation it looks like tibrvTransport_Send
isn't supposed to block, so we have to just assume it's
doing internal buffering.
libtibrv doesn ' t provide an explicit " async send " routine From the documentation it looks like tibrvTransport_Send isn ' t supposed to block so we have to just assume it ' s doing internal buffering .
&mut self
item
Msg