Struct WorkerEmulator 

pub struct WorkerEmulator { /* private fields */ }

Web Worker emulator for testing message passing and state transitions

Implements Lamport (1978) message ordering guarantees for verification.

Example

use jugar_probar::capabilities::{WorkerEmulator, WorkerMessage, WorkerState};

let mut emulator = WorkerEmulator::new();
emulator.spawn("audio_processor");

// Simulate worker initialization
emulator.send(WorkerMessage::new("Init", serde_json::json!({"model": "tiny"})));
assert_eq!(emulator.state(), WorkerState::Loading);

emulator.receive_response(WorkerMessage::new("Ready", serde_json::json!({})));
assert_eq!(emulator.state(), WorkerState::Ready);

Implementations

impl WorkerEmulator

pub fn new() -> Self

Create a new worker emulator

pub fn spawn(&mut self, name: impl Into<String>)

Spawn a named worker

pub fn state(&self) -> WorkerState

Get current worker state

pub fn name(&self) -> &str

Get worker name

pub fn send(&mut self, message: WorkerMessage)

Send a message to the worker

pub fn receive_response(&mut self, response: WorkerMessage)

Receive a response from the worker

pub fn terminate(&mut self)

Terminate the worker

pub fn pending_messages(&self) -> &[WorkerMessage]

Get pending messages

pub fn responses(&self) -> &[WorkerMessage]

Get received responses

pub fn lamport_time(&self) -> u64

Get current Lamport timestamp

pub fn history(&self) -> &[(u64, String, String)]

Get message history for verification

pub fn with_delays(self, enable: bool) -> Self

Enable delay simulation

pub fn clear(&mut self)

Clear all queues

pub fn verify_ordering(&self) -> bool

Verify message ordering (Lamport guarantee)

Returns true if all messages maintain causal ordering.

pub fn assert_state(&self, expected: WorkerState) -> Result<(), CapabilityError>

Assert worker is in expected state

Errors

Returns error if worker is not in expected state.

pub fn ready(name: impl Into<String>) -> Self

Create emulator with simulated worker ready

pub fn interception_js() -> &'static str

Generate JavaScript to intercept Worker constructor

Trait Implementations

impl Clone for WorkerEmulator

fn clone(&self) -> WorkerEmulator

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkerEmulator

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

Formats the value using the given formatter.

impl Default for WorkerEmulator

fn default() -> Self

Returns the “default value” for a type.