Struct ArcClient 

pub struct ArcClient(/* private fields */);

An owned transport shared through an Arc.

The named type keeps the trait object’s lifetime out of generic async return types. This lets those futures retain their native Send bound. Clones share the same transport allocation and connection state.

Trait Implementations

impl Client for ArcClient

fn host(&self) -> &str

The URL this transport dials — its connection identity. Two clients share process-level connection state (the XIP-83 shared bidi wire) exactly when their hosts match, so this must name where the bytes actually go: a client behind a proxy reports the proxy’s URL, keeping it a separate failure domain from a direct client to the same backend.

fn has_credential_source(&self) -> bool

Whether this transport stack was given a way to obtain a credential — an auth callback or an auth handle (CFG-062). A stack with no auth middleware in it reports false, and build refuses a deployment that requires authentication.

fn request<'life0, 'async_trait>( &'life0 self, request: Builder, path: PathAndQuery, body: Bytes, ) -> Pin<Box<dyn Future<Output = Result<Response<Bytes>, ApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stream<'life0, 'async_trait>( &'life0 self, request: Builder, path: PathAndQuery, body: Bytes, ) -> Pin<Box<dyn Future<Output = Result<Response<BytesStream>, ApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn bidi_stream<'life0, 'async_trait>( &'life0 self, request: Builder, path: PathAndQuery, body: BoxDynStream<'static, Bytes>, ) -> Pin<Box<dyn Future<Output = Result<Response<BytesStream>, ApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Open a bidirectional stream (XIP-83). body is the outbound stream of encoded protobuf messages (one Bytes item per message); the response carries the inbound message stream. Transports without full-duplex support (e.g. gRPC-Web in the browser) keep this default and error.

fn fake_stream(&self) -> Response<BytesStream>

start a “fake” stream that does not create a TCP connection and will always be pending

impl Clone for ArcClient

fn clone(&self) -> ArcClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Deref for ArcClient

type Target = Arc<dyn BoxClientT>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<Arc<dyn BoxClientT>> for ArcClient

fn from(client: Arc<dyn BoxClientT>) -> Self

Converts to this type from the input type.

impl IsConnectedCheck for ArcClient

fn is_connected<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if a client is connected