Struct FakeDriver 

pub struct FakeDriver { /* private fields */ }

In-memory WorkflowDriver with scripted replies.

Unmatched spawns complete immediately with done:<description>. Rules are matched by substring against the request description, first match wins.

Implementations

impl FakeDriver

pub fn new() -> Self

A fake with no rules, no budget ceiling, and echo replies.

pub fn on(&self, needle: &str, reply: FakeReply)

Add a reply rule: requests whose description contains needle get reply immediately.

pub fn on_with_delay(&self, needle: &str, reply: FakeReply, delay: Duration)

Like FakeDriver::on, but the completion is delivered after delay (the spawn itself still returns immediately).

pub fn set_budget(&self, total: Option<u64>, spend_per_task: u64)

Configure the budget pool: ceiling plus a fixed spend debited at each spawn (simulating the driver-side reservation of design §5.3).

pub fn requests(&self) -> Vec<TaskRequest>

Every request received so far, in spawn order.

pub fn request_descriptions(&self) -> Vec<String>

Descriptions of every request, in spawn order.

pub fn spawn_count(&self) -> usize

Number of admitted spawn calls.

pub fn events(&self) -> Vec<ProgressEvent>

Every progress event received so far, in emit order.

pub fn cancel_all_calls(&self) -> usize

How many times cancel_all has been invoked.

Trait Implementations

impl Debug for FakeDriver

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

Formats the value using the given formatter.

impl Default for FakeDriver

fn default() -> FakeDriver

Returns the “default value” for a type.

impl WorkflowDriver for FakeDriver

fn spawn_task<'life0, 'async_trait>( &'life0 self, request: TaskRequest, ) -> Pin<Box<dyn Future<Output = Result<SpawnedTask, DriverError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Admit and start one task. Errors surface as a JS throw on the corresponding task() call.

fn cancel_all(&self)

Cancel every in-flight task belonging to this run. Idempotent.

fn budget(&self) -> BudgetSnapshot

Current snapshot of the run’s shared token pool.

fn progress(&self, event: ProgressEvent)

Receive a script progress event (ordered, synchronous).