Trait FlowController 

pub trait FlowController {
    // Required methods
    fn send(
        &mut self,
        message: Box<dyn OutgoingMessage>,
        ack: Promise<(), Error>,
    ) -> Promise<(), Error>;
    fn wait_all_acked(&mut self) -> Promise<(), Error>;
}

Tracks a particular RPC stream in order to implement a flow control algorithm.

Required Methods

fn send( &mut self, message: Box<dyn OutgoingMessage>, ack: Promise<(), Error>, ) -> Promise<(), Error>

fn wait_all_acked(&mut self) -> Promise<(), Error>

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors