Enum WaitForTokenError 

pub enum WaitForTokenError {
    Timeout,
    WrongOrigin {
        token_origin: u64,
        adapter_origin: u64,
    },
    QueueFull,
    FoldStopped {
        applied_through_seq: Option<u64>,
    },
}

Errors surfaced by CortexAdapter::wait_for_token and the origin-bound adapters that wrap it.

Variants

Timeout

Deadline elapsed before the fold watermark advanced to the token’s seq. The write may still land later; the caller can retry with a fresh deadline or accept the stale read.

WrongOrigin

Token belongs to a different origin than this adapter folds. Origin-bound adapters surface this to catch the caller-side aliasing where a token from chain A is waited on against an adapter bound to chain B — the wait would otherwise hang on a seq that can never land here.

Fields

token_origin: u64

origin the token was issued for.

adapter_origin: u64

origin this adapter is bound to.

QueueFull

Per-channel in-flight cap is saturated — back-pressure for callers who can shed load instead of stacking unbounded pending waits. See super::config::CortexAdapterConfig::with_ryw_inflight_cap.

FoldStopped

Fold task stopped before the token’s seq was reached. Under FoldErrorPolicy::Stop an unrecoverable fold error halts the task, and any pending RYW wait observing running == false surfaces this variant rather than a silent Ok(()) — otherwise a producer cannot distinguish “your write is visible” from “the adapter is dead and never will reach your write.”

Fields

applied_through_seq: Option<u64>

Last seq the fold task fully applied before stopping. None if the task stopped before applying any event.

Trait Implementations

impl Debug for WaitForTokenError

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

Formats the value using the given formatter.

impl Display for WaitForTokenError

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

Formats the value using the given formatter.

impl Error for WaitForTokenError

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.

impl PartialEq for WaitForTokenError

fn eq(&self, other: &WaitForTokenError) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for WaitForTokenError

impl StructuralPartialEq for WaitForTokenError