Struct Client 

pub struct Client<P: Protocol> { /* private fields */ }

Cheap shared handle to one reader, writer, allocator, and set of subscriptions.

Implementations

impl<P: Protocol> Client<P>

pub async fn connect(path: impl AsRef<Path>) -> ClientResult<Self>

Connect a native endpoint with a single total setup deadline.

pub async fn connect_with( path: impl AsRef<Path>, configure: impl FnOnce(ConnectOptions) -> ConnectOptions, ) -> ClientResult<Self>

Configure a native connection without modifying its endpoint name.

pub async fn connect_connector(connector: &dyn Connector) -> ClientResult<Self>

Connect through a supplied repeatable dialer.

pub async fn connect_connector_with( connector: &dyn Connector, configure: impl FnOnce(ConnectOptions) -> ConnectOptions, ) -> ClientResult<Self>

Configure one deadline covering both dial and protocol establishment.

pub async fn connect_stream(stream: impl ByteTransport) -> ClientResult<Self>

Establish the protocol on an exclusively owned caller transport.

pub async fn connect_stream_with( stream: impl ByteTransport, configure: impl FnOnce(ConnectOptions) -> ConnectOptions, ) -> ClientResult<Self>

Configure setup for an already-dialed owned transport.

pub async fn from_established( established: Established<P::Ready>, ) -> ClientResult<Self>

Start routing after external protocol setup, validating ranges and limits.

pub fn ready(&self) -> &P::Ready

Shared immutable ready/welcome metadata.

pub fn is_closed(&self) -> bool

Whether the shared connection has terminated.

pub async fn closed(&self)

Wait for shared closure, including an idle peer disconnect. Cancellation of this wait does not close the connection or affect other callers.

pub async fn close(&self)

Close all shared handles and wake every waiter; never reconnect implicitly.

pub async fn request<M: IntoOutboundMessage<P>>( &self, message: M, ) -> ClientResult<Message>

Return the first response and retain drain state if it is nonterminal.

pub async fn request_with<M: IntoOutboundMessage<P>>( &self, message: M, configure: impl FnOnce(RequestOptions) -> RequestOptions, ) -> ClientResult<Message>

Configure a local unary wait without imposing application success rules.

pub async fn request_typed<R: Request<P>>( &self, request: &R, ) -> Result<R::Response, R::Error>

Execute a borrowed prepared request with optional checked result decoding.

pub async fn request_typed_with<R: Request<P>>( &self, request: &R, configure: impl FnOnce(RequestOptions) -> RequestOptions, ) -> Result<R::Response, R::Error>

Configure one checked unary attempt; unexpected streaming is an error.

pub async fn stream<M: IntoOutboundMessage<P>>( &self, message: M, ) -> ClientResult<Stream<P>>

Open a message stream on an owned correlation ID.

pub async fn stream_with<M: IntoOutboundMessage<P>>( &self, message: M, configure: impl FnOnce(RequestOptions) -> RequestOptions, ) -> ClientResult<Stream<P>>

Configure the stream-opening wait; subsequent receives own their lifetime.

pub async fn request_raw( &self, flags: u8, body: Vec<u8>, ) -> ClientResult<RawFrame>

Return one raw frame without decoding or normalizing its envelope.

pub async fn request_raw_with( &self, flags: u8, body: Vec<u8>, configure: impl FnOnce(RequestOptions) -> RequestOptions, ) -> ClientResult<RawFrame>

Set a deadline covering queue admission, write completion, and reply wait.

pub async fn stream_raw( &self, flags: u8, body: Vec<u8>, ) -> ClientResult<RawStream<P>>

Open an opaque stream with the same ID lease as native message streams.

pub async fn stream_raw_with( &self, flags: u8, body: Vec<u8>, configure: impl FnOnce(RequestOptions) -> RequestOptions, ) -> ClientResult<RawStream<P>>

Configure opaque stream opening without inspecting its envelope.

pub async fn send<M: IntoOutboundMessage<P>>( &self, id: u32, message: M, ) -> ClientResult<()>

Send a native or encoded payload on a currently live owned ID.

pub async fn send_raw( &self, id: u32, flags: u8, body: &[u8], ) -> ClientResult<()>

Send an opaque envelope on a currently live owned ID.

pub async fn write_unchecked(&self, packet: Vec<u8>) -> ClientResult<()>

Serialize exact packet bytes without allocating an ID or subscription. The caller owns packet semantics; byte limits and shared close still apply.

Trait Implementations

impl<P: Protocol> Clone for Client<P>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.