Struct UnboundedBidiStreamHandle 

pub struct UnboundedBidiStreamHandle<REQ, RSP> {
    pub request_sender: UnboundedSender<REQ>,
    pub response_stream: BoxStream<'static, Result<RSP>>,
}

The handle of a bidi-stream started from the rpc client. It is similar to the BidiStreamHandle except that its sender is unbounded.

Fields

request_sender: UnboundedSender<REQ>

response_stream: BoxStream<'static, Result<RSP>>

Implementations

impl<REQ, RSP> UnboundedBidiStreamHandle<REQ, RSP>

pub async fn initialize<F: FnOnce(UnboundedReceiver<REQ>) -> Fut, St: Stream<Item = Result<RSP>> + Send + Unpin + 'static, Fut: Future<Output = Result<St>> + Send, R: Into<REQ>>( first_request: R, init_stream_fn: F, ) -> Result<(Self, RSP)>

pub async fn next_response(&mut self) -> Result<RSP>

pub fn send_request(&mut self, request: REQ) -> Result<()>

Trait Implementations

impl<REQ, RSP> Debug for UnboundedBidiStreamHandle<REQ, RSP>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.