Struct Connection 

pub struct Connection { /* private fields */ }

A live connection to one RPC proxy.

Dropping it ends both background tasks and releases the socket. That is not automatic: the writer stops on its own once the last sender is gone, but the reader would stay parked in receive() holding the read half until the peer closed — and against a peer that never does, the task and its file descriptor would live as long as the process.

Implementations

impl Connection

pub async fn connect(address: &str, token: Option<String>) -> Result<Self>

Connects to a proxy and starts the reader and writer tasks.

pub fn address(&self) -> &str

The address this connection was opened to.

pub fn is_closed(&self) -> bool

Whether the connection has failed or been closed.

pub async fn invoke<Response: Message + Default>( &self, method: &str, body: &impl Message, attachments: Vec<Bytes>, timeout: Option<Duration>, response_name: &'static str, ) -> Result<(Response, Vec<Bytes>)>

Calls one method and waits for its response.

The timeout is sent to the server in the request header and applied locally, so the two agree: a local-only timeout would leave the proxy working, and a server-only one would leave the caller waiting if the connection stalled.

pub async fn invoke_raw( &self, service: &str, method: &str, body: &impl Message, attachments: Vec<Bytes>, timeout: Option<Duration>, mutation_id: Option<Guid>, ) -> Result<ResponseMessage>

Calls one method, returning the whole response message.

Trait Implementations

impl Debug for Connection

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

Formats the value using the given formatter.

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.