Trait dataflow_types::client::Client[−][src]

pub trait Client: Send {
    fn send<'life0, 'async_trait>(
        &'life0 mut self, 
        cmd: Command
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;

    fn recv<'life0, 'async_trait>(
        &'life0 mut self
    ) -> Pin<Box<dyn Future<Output = Option<Response>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}
Expand description

A client to a running dataflow server.

Required methods

Sends a command to the dataflow server.

Receives the next response from the dataflow server.

This method blocks until the next response is available, or, if the dataflow server has been shut down, returns None.

Implementations on Foreign Types

Implementors