Trait flow_sdk::client::GrpcClient

pub trait GrpcClient<I, O> {
    type Error: Into<Box<dyn Error + Send + Sync>>;
    fn send<'a>(
        &'a mut self, 
        input: I
    ) -> Pin<Box<dyn Future<Output = Result<O, Self::Error>> + 'a>>;
}

A gRPC client trait.

Implementors should be generic over the input and output types, but it is not required.

Associated Types

type Error: Into<Box<dyn Error + Send + Sync>>

The error type of the client.

Required methods

fn send<'a>(
    &'a mut self,
    input: I
) -> Pin<Box<dyn Future<Output = Result<O, Self::Error>> + 'a>>

Sends a request with the client. Returns a future that evaluates a Result, potentially containing the output.

Implementations on Foreign Types

impl<'t, T, I, O> GrpcClient<I, O> for &'t mut T where
    T: GrpcClient<I, O>, 

type Error = T::Error

fn send<'a>(
    &'a mut self,
    input: I
) -> Pin<Box<dyn Future<Output = Result<O, Self::Error>> + 'a>>

impl<I, O, Service> GrpcClient<I, O> for Grpc<Service> where
    I: FlowRequest<O> + Send + Sync + EncodableMessage,
    O: for<'b> DecodableMessage<'b> + Send + Sync + Default + 'static,
    Service: GrpcService<BoxBody> + 'static,
    Service::Error: Into<Box<dyn Error + Send + Sync>>,
    Service::ResponseBody: Body + Send + Sync + 'static,
    <Service::ResponseBody as Body>::Error: Into<Box<dyn Error + Send + Sync>>, 

type Error = TonicError

fn send(&mut self, input: I) -> GrpcSendResult<'_, O>

Implementors

impl<Inner, I, O> GrpcClient<I, O> for FlowClient<Inner> where
    Inner: GrpcClient<I, O>, 

type Error = Inner::Error