Struct WaitForConditionConfig 

pub struct WaitForConditionConfig<S> {
    pub initial_state: S,
    pub wait_strategy: Box<dyn Fn(&S, usize) -> WaitDecision + Send + Sync>,
    pub timeout: Option<Duration>,
    pub serdes: Option<Arc<dyn SerDesAny>>,
}

Configuration for wait_for_condition operations.

Fields

initial_state: S

Initial state to pass to the check function.

wait_strategy: Box<dyn Fn(&S, usize) -> WaitDecision + Send + Sync>

Wait strategy function that determines polling behavior.

Takes a reference to the current state and the attempt number (1-indexed), and returns a WaitDecision.

timeout: Option<Duration>

Overall timeout for the operation.

serdes: Option<Arc<dyn SerDesAny>>

Optional custom serializer/deserializer.

Implementations

impl<S> WaitForConditionConfig<S>

pub fn from_interval( initial_state: S, interval: Duration, max_attempts: Option<usize>, ) -> Self

where S: Send + Sync + 'static,

Creates a backward-compatible WaitForConditionConfig from interval and max_attempts.

This constructor converts the old-style interval + max_attempts parameters into a wait strategy that uses a fixed delay (no backoff, no jitter).

Arguments

• initial_state - Initial state to pass to the check function.
• interval - Fixed interval between condition checks.
• max_attempts - Maximum number of attempts (None for unlimited).

Example

use durable_execution_sdk::{WaitForConditionConfig, Duration};

let config = WaitForConditionConfig::from_interval(
    my_initial_state,
    Duration::from_seconds(5),
    Some(10),
);

Trait Implementations

impl<S> Debug for WaitForConditionConfig<S>

where S: Debug,

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

Formats the value using the given formatter.

impl<S: Default + Send + Sync + 'static> Default for WaitForConditionConfig<S>

fn default() -> Self

Returns the “default value” for a type.