Struct ConnectClient 

pub struct ConnectClient { /* private fields */ }

Minimal h2c Connect client.

Implementations

impl ConnectClient

pub fn new(endpoint: impl Into<String>, bearer: Option<String>) -> Self

Create a client for an HTTP endpoint.

pub async fn unary<Req, Resp>( &self, path: &str, request: &Req, ) -> Result<Resp, ConnectClientError>

where Req: Message, Resp: Message + Default,

Execute a unary Connect request.

Errors

Returns an error when the endpoint, connection, HTTP exchange, or protobuf encoding/decoding fails, or when Connect returns an error.

pub async fn streaming<Req, Resp>( &self, path: &str, request: &Req, ) -> Result<Receiver<Result<Resp, ConnectClientError>>, ConnectClientError>

where Req: Message, Resp: Message + Default + Send + 'static,

Execute a Connect client-streaming/server-streaming request with one start message.

Errors

Returns an error when the endpoint, connection, HTTP exchange, or protobuf encoding fails, or when Connect rejects the stream.

Trait Implementations

impl Clone for ConnectClient

fn clone(&self) -> ConnectClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectClient

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

Formats the value using the given formatter.