Struct Grpc

pub struct Grpc<T> { /* private fields */ }

gRPC client handle.

Takes an HTTP service and adds the gRPC protocol.

Implementations

impl<T> Grpc<T>

pub fn new(inner: T) -> Self

Create a new Grpc instance backed by the given HTTP service.

pub fn poll_ready<R>(&mut self) -> Poll<(), Status>

where T: GrpcService<R>,

Returns Ready when the service is ready to accept a request.

pub fn ready<R>(self) -> impl Future<Item = Self, Error = Status>

where T: GrpcService<R>,

Consumes self, returning a future that yields self back once it is ready to accept a request.

pub fn unary<M1, M2, R>( &mut self, request: Request<M1>, path: PathAndQuery, ) -> ResponseFuture<M2, T::Future, T::ResponseBody>

where T: GrpcService<R>, Once<M1>: Encodable<R>,

Send a unary gRPC request.

pub fn client_streaming<B, M, R>( &mut self, request: Request<B>, path: PathAndQuery, ) -> ResponseFuture<M, T::Future, T::ResponseBody>

where T: GrpcService<R>, B: Encodable<R>,

Send a client streaing gRPC request.

pub fn server_streaming<M1, M2, R>( &mut self, request: Request<M1>, path: PathAndQuery, ) -> ResponseFuture<M2, T::Future>

where T: GrpcService<R>, Once<M1>: Encodable<R>,

Send a server streaming gRPC request.

pub fn streaming<B, M, R>( &mut self, request: Request<B>, path: PathAndQuery, ) -> ResponseFuture<M, T::Future>

where T: GrpcService<R>, B: Encodable<R>,

Initiate a full streaming gRPC request

Generics

B: The request stream of gRPC message values. M: The response message (not stream) type. R: The type of the request body.

Trait Implementations

impl<T: Clone> Clone for Grpc<T>

fn clone(&self) -> Grpc<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Grpc<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.