fn new(inner: C) -> InterceptingDataflowClient<C> {
        let (feedback_tx, feedback_rx) = mpsc::unbounded_channel();
        InterceptingDataflowClient {
            inner: Arc::new(TokioMutex::new(inner)),
            feedback_tx,
            feedback_rx: Arc::new(TokioMutex::new(feedback_rx)),
        }
    }
/// Creates a new intercepting dataflow client that wraps the provided
/// dataflow client.
Creates a new intercepting dataflow client that wraps the provided
dataflow client.
Creates a new intercepting dataflow client that wraps the provided dataflow client .
fn new(inner: C) -> InterceptingDataflowClient<C> {
        let (feedback_tx, feedback_rx) = mpsc::unbounded_channel();
        InterceptingDataflowClient {
            inner: Arc::new(TokioMutex::new(inner)),
            feedback_tx,
            feedback_rx: Arc::new(TokioMutex::new(feedback_rx)),
        }
    }
fn new ( inner : C ) -> InterceptingDataflowClient < C > { let ( feedback_tx , feedback_rx ) = mpsc :: unbounded_channel ( ) ; InterceptingDataflowClient { inner : Arc :: new ( TokioMutex :: new ( inner ) ) , feedback_tx , feedback_rx : Arc :: new ( TokioMutex :: new ( feedback_rx ) ) , } }
Creates a new intercepting dataflow client that wraps the provided
dataflow client.
Creates a new intercepting dataflow client that wraps the provided dataflow client .
inner
C
inner
C