Enum StreamError 

pub enum StreamError {
    ConnectionFailed {
        url: String,
        reason: String,
    },
    Disconnected {
        url: String,
    },
    ReconnectExhausted {
        url: String,
        attempts: u32,
    },
    ParseError {
        exchange: String,
        reason: String,
    },
    StaleFeed {
        feed_id: String,
        elapsed_ms: u64,
        threshold_ms: u64,
    },
    BookReconstructionFailed {
        symbol: String,
        reason: String,
    },
    BookCrossed {
        symbol: String,
        bid: String,
        ask: String,
    },
    Backpressure {
        channel: String,
        depth: usize,
        capacity: usize,
    },
    UnknownExchange(String),
    Io(String),
    WebSocket(String),
}

Variants

ConnectionFailed

WebSocket connection failed.

Fields

url: String

reason: String

Disconnected

WebSocket disconnected unexpectedly.

Fields

url: String

ReconnectExhausted

Reconnection attempts exhausted.

Fields

url: String

attempts: u32

ParseError

Tick deserialization failed.

Fields

exchange: String

reason: String

StaleFeed

Feed is stale — no data received within staleness threshold.

Fields

feed_id: String

elapsed_ms: u64

threshold_ms: u64

BookReconstructionFailed

Order book reconstruction failed.

Fields

symbol: String

reason: String

BookCrossed

Order book is crossed (bid >= ask).

Fields

symbol: String

bid: String

ask: String

Backpressure

Backpressure: the downstream channel is full.

Fields

channel: String

depth: usize

capacity: usize

UnknownExchange(String)

Invalid exchange format.

Io(String)

I/O error.

WebSocket(String)

WebSocket protocol error.

Trait Implementations

impl Debug for StreamError

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

Formats the value using the given formatter.

impl Display for StreamError

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

Formats the value using the given formatter.

impl Error for StreamError

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.