Trait mz_dataflow_types::client::grpc::BidiProtoClient

pub trait BidiProtoClient {
    type ProtoCommand;
    type ProtoResponse;
    fn connect<'async_trait>(
        addr: String
    ) -> Pin<Box<dyn Future<Output = Result<Self, Error>> + Send + 'async_trait>>
    where
        Self: Sized,
        Self: 'async_trait;
    fn create_stream<'life0, 'async_trait>(
        &'life0 mut self, 
        rx: UnboundedReceiver<Self::ProtoCommand>
    ) -> Pin<Box<dyn Future<Output = Result<Streaming<Self::ProtoResponse>, Error>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

Encapsulates the core functionality of a prost client for a bidirectional stream.

The implementations for this trait MUST be identical minus the types

Associated Types

type ProtoCommand

type ProtoResponse

Required methods

fn connect<'async_trait>(
    addr: String
) -> Pin<Box<dyn Future<Output = Result<Self, Error>> + Send + 'async_trait>> where
    Self: Sized,
    Self: 'async_trait, 

fn create_stream<'life0, 'async_trait>(
    &'life0 mut self,
    rx: UnboundedReceiver<Self::ProtoCommand>
) -> Pin<Box<dyn Future<Output = Result<Streaming<Self::ProtoResponse>, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Implementors

impl BidiProtoClient for ProtoComputeClient<Channel>

type ProtoCommand = ProtoComputeCommand

type ProtoResponse = ProtoComputeResponse

impl BidiProtoClient for ProtoStorageClient<Channel>

type ProtoCommand = ProtoStorageCommand

type ProtoResponse = ProtoStorageResponse