Struct UntypedClient

pub struct UntypedClient { /* private fields */ }

Represents a client that can be used to send requests & receive responses from a server.

Note

This variant does not validate the payload of requests or responses being sent and received.

Implementations

impl UntypedClient

pub fn into_typed_client<T, U>(self) -> Client<T, U>

Consumes the client, returning a typed variant.

pub fn into_channel(self) -> UntypedChannel

Convert into underlying channel.

pub fn clone_channel(&self) -> UntypedChannel

Clones the underlying channel for requests and returns the cloned instance.

pub async fn wait(self) -> Result<()>

Waits for the client to terminate, which resolves when the receiving end of the network connection is closed (or the client is shutdown). Returns whether or not the client exited successfully or due to an error.

pub fn abort(&self)

Abort the client’s current connection by forcing its tasks to abort.

pub fn clone_shutdown(&self) -> Box<dyn Shutdown>

Clones the underlying shutdown signaler for the client. This enables you to wait on the client while still having the option to shut it down from somewhere else.

pub async fn shutdown(&self) -> Result<()>

Signal for the client to shutdown its connection cleanly.

pub fn will_shutdown_on_drop(&mut self) -> bool

Returns whether the client should fully shutdown once it is dropped. If true, this will result in all channels tied to the client no longer functioning once the client is dropped.

pub fn shutdown_on_drop(&mut self, shutdown_on_drop: bool)

Sets whether the client should fully shutdown once it is dropped. If true, this will result in all channels tied to the client no longer functioning once the client is dropped.

pub fn clone_connection_watcher(&self) -> ConnectionWatcher

Clones the underlying [ConnectionStateWatcher] for the client.

pub fn on_connection_change<F>(&self, f: F) -> JoinHandle<()>

where F: FnMut(ConnectionState) + Send + 'static,

Spawns a new task that continually monitors for connection changes and invokes the function f whenever a new change is detected.

pub fn is_finished(&self) -> bool

Returns true if client’s underlying event processing has finished/terminated.

pub fn spawn_inmemory( transport: FramedTransport<InmemoryTransport>, config: ClientConfig, ) -> Self

Spawns a client using the provided FramedTransport of InmemoryTransport and a specific ReconnectStrategy.

Note

This will NOT perform any handshakes or authentication procedures nor will it replay any missing frames. This is to be used when establishing a Client to be run internally within a program.

Methods from Deref<Target = UntypedChannel>

pub fn is_closed(&self) -> bool

Returns true if no more requests can be transferred

pub async fn assign_default_mailbox( &self, buffer: usize, ) -> Result<Mailbox<UntypedResponse<'static>>>

Assigns a default mailbox for any response received that does not match another mailbox.

pub async fn remove_default_mailbox(&self) -> Result<()>

Removes the default mailbox used for unmatched responses such that any response without a matching mailbox will be dropped.

pub async fn mail( &mut self, req: UntypedRequest<'_>, ) -> Result<Mailbox<UntypedResponse<'static>>>

Sends a request and returns a mailbox that can receive one or more responses, failing if unable to send a request or if the session’s receiving line to the remote server has already been severed

pub async fn mail_timeout( &mut self, req: UntypedRequest<'_>, duration: impl Into<Option<Duration>>, ) -> Result<Mailbox<UntypedResponse<'static>>>

Sends a request and returns a mailbox, timing out after duration has passed

pub async fn send( &mut self, req: UntypedRequest<'_>, ) -> Result<UntypedResponse<'static>>

Sends a request and waits for a response, failing if unable to send a request or if the session’s receiving line to the remote server has already been severed

pub async fn send_timeout( &mut self, req: UntypedRequest<'_>, duration: impl Into<Option<Duration>>, ) -> Result<UntypedResponse<'static>>

Sends a request and waits for a response, timing out after duration has passed

pub async fn fire(&mut self, req: UntypedRequest<'_>) -> Result<()>

Sends a request without waiting for a response; this method is able to be used even if the session’s receiving line to the remote server has been severed

pub async fn fire_timeout( &mut self, req: UntypedRequest<'_>, duration: impl Into<Option<Duration>>, ) -> Result<()>

Sends a request without waiting for a response, timing out after duration has passed

Trait Implementations

impl Debug for UntypedClient

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

Formats the value using the given formatter.

impl Deref for UntypedClient

type Target = UntypedChannel

The resulting type after dereferencing.

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

Dereferences the value.

impl DerefMut for UntypedClient

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl Drop for UntypedClient

fn drop(&mut self)

Executes the destructor for this type.

impl From<UntypedClient> for UntypedChannel

fn from(client: UntypedClient) -> Self

Converts to this type from the input type.