Struct Wait 

pub struct Wait { /* private fields */ }

Describes when Dex may invoke a Step’s execute handler.

Build waits from durable timer and Channel Condition values. Combinators consume their inputs and preserve order, which determines timer indexes used by crate::TimerId.

Examples

use dex_sdk::{Channel, Timer, Wait};
use std::time::Duration;

let approvals = Channel::<String>::new("approvals");
let wait = Wait::any_of([
    approvals.for_one(),
    Timer::by_duration(Duration::from_secs(300)),
]);

Implementations

impl Wait

pub fn skip_immediately() -> Self

Skips wait_for and asks Dex to invoke execute immediately.

pub fn until(condition: Condition) -> Self

Waits until one condition is satisfied. The Condition does not need an ID.

pub fn all_of(conditions: impl IntoIterator<Item = Condition>) -> Self

Waits until every condition is satisfied. Conditions do not need IDs.

pub fn any_of(conditions: impl IntoIterator<Item = Condition>) -> Self

Waits until at least one condition is satisfied. Conditions do not need IDs.

Among ready conditions, Dex selects the first in canonical order: Timers, Channels, then SubFlows, preserving iterator order within each kind. An unready condition does not block a later ready condition. To wait for strict priority, return only the higher-priority condition.

Channel consumption is not greedy across alternatives. Only the selected Channel condition consumes messages; other ready Channel conditions consume nothing.

pub fn any_combination_of( combinations: impl IntoIterator<Item = ConditionCombination>, ) -> Self

Waits for every Condition in any combination.

Channel consumption is limited to Channel conditions in the selected combination. Conditions belonging only to other ready combinations consume nothing.

Every Condition needs a non-empty user ID. Clones of the same Condition may be reused across combinations; distinct Conditions need unique IDs.