Enum NatsError 

#[non_exhaustive]
pub enum NatsError {
    Connect(Box<dyn StdError + Send + Sync>),
    Publish(Box<dyn StdError + Send + Sync>),
    Subscribe(Box<dyn StdError + Send + Sync>),
    JetStream(Box<dyn StdError + Send + Sync>),
    Shutdown(Box<dyn StdError + Send + Sync>),
    RequestTimeout,
    Closed {
        subject: String,
    },
    InvalidOptions(String),
}

Errors surfaced by the NATS broker implementation.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Connect(Box<dyn StdError + Send + Sync>)

Failed to establish or use the underlying async-nats connection.

Publish(Box<dyn StdError + Send + Sync>)

Failed to publish a message to the broker.

Subscribe(Box<dyn StdError + Send + Sync>)

Failed to subscribe to the requested subject.

JetStream(Box<dyn StdError + Send + Sync>)

JetStream-specific operation failed (consumer creation, publish acknowledgement, ack).

Shutdown(Box<dyn StdError + Send + Sync>)

Draining the connection during shutdown failed.

RequestTimeout

A request / reply operation timed out before a reply was received.

Closed

A publisher aliasing the connection was used after the broker shut down.

The lifecycle ladder makes misuse through the owner’s handle a compile error: ConnectedBroker::shutdown consumes the connected broker. Publishers paired off it earlier keep aliasing the closed connection, so their operations report this instead of silently succeeding against a dead connection.

Fields

subject: String

The subject the closed publisher was asked to reach.

InvalidOptions(String)

The subscription descriptor names an empty subject. Combinations of settings the broker cannot honour are rejected by the types instead, so this is what is left: a subject is a string the caller supplies, often from configuration.

Trait Implementations

impl Debug for NatsError

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

Formats the value using the given formatter.

impl Display for NatsError

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

Formats the value using the given formatter.

impl Error for NatsError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

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

Provides type-based access to context intended for error reports.