Tries to get the next client event. When the client dies, the last event emitted will be `ClientEvent::Report(ClientReport::IsDead))`. After a clien

Sends a one-shot message to the server. Returns `Ok(MessageSignal)` on success. The signal can be used to track the message status. Messages will fai

Makes a new client.

Close the session

Access this client's id.

Makes a new server with a default [`axum::Router`]. Only works with a tokio runtime handle.

Gets the server's url.

Sends a request to the server. Returns `RequestSignal`. The signal can be used to track the message status. Requests will fail if the underlying clie

Sends a message to the target client. Messages will be silently dropped if the client is not connected *or* if the client is connected but there are

The id of the client that sent this request.

Access the inner request signal tracker.

Tests if the server is dead.

Gets the next available server event.

Acknowledges a client request. Messages will be silently dropped if the specific session that produced the original request is not connected. Note th

Add a new pending request.

Checks if the token has expired.

Closes the client. Any in-progress messages may or may not fail once this method is called. New messages and requests cannot be sent after this metho

Check if the destination session is dead. Request tokens are tied to a specific server session. When a client reconnects they get a new session and o

Tests if the client is dead (no longer connected to the server and won't reconnect). - Note that [`ClientReport::IsDead`] will be emitted by [`Client:

Set the status of a pending request and remove it from the tracker.

Consume the token, preventing it from sending a rejection message when dropped.

Disconnects the target client. The client's session may remain open until some time after this method is called.

Get the binary's target environment.

Generates a privkey/pubkey pair for use in creating and verifying [`AuthTokens`](AuthToken). The private key is a security-critical secret that shoul

Tests if the client is closed. Returns true after [`Client::close()`] has been called, or once the internal client dies. Messages and requests canno

Tests if the client is connected. Messages and requests cannot be submitted when the client is not connected.

The request id defined by the client who sent this request.

Abort and drain all pending requests. pub(crate) fn abort_all(&mut self) -> impl Iterator<Item = RequestSignal> + '_

Authenticates an auth request.

Convert requests with [`MessageStatus::Sent`] or [`MessageStatus::Failed`] to [`RequestStatus::ResponseLost`] and drain them. todo: use extract_if onc

Convert [`EnvType`] to a string.

Get an [`EnvType`] from a string.

Gets the duration after `UNIX_EPOCH` when the token will expire.

Extract connection info from a connection request. Assumes the request has already been pre-validated.

Makes an [`AuthToken`] from an expiration time in seconds since `UNIX_EPOCH`.

Makes an [`AuthToken`] from a token lifetime. The token will expire at `current time + lifetime`.

Make a websocket url: `{ws, wss}://[ip:port]/ws`.

Makes a new server with a user-constructed [`axum::Router`]. Only works with a tokio runtime handle.

Rejects a client request.

Reserve a request id.

Responds to a client request. Messages will be silently dropped if the specific session that produced the original request is not connected. Note tha

Gets the time remaining before the token expires.

Try to add a message to the tracker. - Fails if adding the message violates the rate limit.