Struct coordtest::InterceptingDataflowClient

pub(crate) struct InterceptingDataflowClient<C> {
    pub(crate) inner: Arc<TokioMutex<C>>,
    pub(crate) feedback_tx: UnboundedSender<Response>,
    pub(crate) feedback_rx: Arc<TokioMutex<UnboundedReceiver<Response>>>,
}

A dataflow_types::client::Client implementation that intercepts responses from the dataflow server.

The implementation of the send method is unchanged. The implementation of recv, however, only presents the responses that have been explicitly forwarded via forward_response. To access the actual responses from the underlying dataflow client, call try_intercepting_recv.

Fields

inner: Arc<TokioMutex<C>>

feedback_tx: UnboundedSender<Response>

feedback_rx: Arc<TokioMutex<UnboundedReceiver<Response>>>

Implementations

impl<C> InterceptingDataflowClient<C> where
    C: Client, 

pub(crate) fn new(inner: C) -> InterceptingDataflowClient<C>

Creates a new intercepting dataflow client that wraps the provided dataflow client.

pub(crate) async fn intercepting_recv(&mut self) -> Option<Response>

Receives a response from the underlying dataflow client, if one is immediately available.

pub(crate) fn forward_response(&self, response: Response)

Makes the specified response available via the normal recv method.

Trait Implementations

impl<C> Client for InterceptingDataflowClient<C> where
    C: Client, 

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, 

Sends a command to the dataflow server.

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, 

Receives the next response from the dataflow server.

impl<C> Clone for InterceptingDataflowClient<C>

fn clone(&self) -> InterceptingDataflowClient<C>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.