Struct AsyncChildTestHarness 

pub struct AsyncChildTestHarness<C: AsyncRunnableChild> { /* private fields */ }

Test harness for asynchronous AsyncRunnableChild implementations.

Provides async run() testing with automatic time measurement and timeout support.

Example

use orcs_component::testing::AsyncChildTestHarness;
use orcs_component::{Child, AsyncRunnableChild, ChildResult, async_trait};
use serde_json::{json, Value};
use std::time::Duration;

struct AsyncWorker { /* ... */ }

#[async_trait]
impl AsyncRunnableChild for AsyncWorker {
    async fn run(&mut self, input: Value) -> ChildResult {
        tokio::time::sleep(Duration::from_millis(10)).await;
        ChildResult::Ok(json!({"processed": input}))
    }
}

#[tokio::test]
async fn test_async_worker() {
    let worker = AsyncWorker::new();
    let mut harness = AsyncChildTestHarness::new(worker)
        .with_default_timeout(Duration::from_secs(5));

    let result = harness.run(json!({"task": "test"})).await;
    assert!(result.is_ok());

    // Test timeout
    let slow_result = harness
        .run_with_timeout(json!({}), Duration::from_millis(1))
        .await;
    assert!(slow_result.is_err());
}

Implementations

impl<C: AsyncRunnableChild> AsyncChildTestHarness<C>

pub fn new(child: C) -> Self

Creates a new test harness for the given async runnable child.

Time measurement is enabled by default.

pub fn without_time_measurement(self) -> Self

Disables time measurement.

pub fn with_default_timeout(self, timeout: Duration) -> Self

Sets the default timeout for run operations.

pub async fn run(&mut self, input: Value) -> ChildResult

Executes async run() on the child with the given input.

If a default timeout is set, it will be applied.

pub async fn run_with_timeout( &mut self, input: Value, timeout: Duration, ) -> Result<ChildResult, TimeoutError>

Executes async run() with a timeout.

Returns Err(TimeoutError) if the operation times out.

pub async fn run_json<T: Serialize>(&mut self, input: T) -> ChildResult

Executes async run() with a serializable input.

pub fn run_log(&self) -> &[RunRecord]

Returns the run log for snapshot testing.

pub fn clear_all_logs(&mut self)

Clears all logs (both run and signal).

pub fn child(&self) -> &C

Returns a reference to the child under test.

pub fn child_mut(&mut self) -> &mut C

Returns a mutable reference to the child under test.

pub fn id(&self) -> &str

Returns the child’s ID.

pub fn status(&self) -> Status

Returns the current status of the child.

pub fn send_signal(&mut self, signal: Signal) -> SignalResponse

Sends a signal to the child.

pub fn veto(&mut self) -> SignalResponse

Sends a Veto signal to the child.

pub fn cancel(&mut self) -> SignalResponse

Sends a Cancel signal to the child.

pub fn abort(&mut self)

Calls abort() on the child.

pub fn signal_log(&self) -> &[SignalRecord]

Returns the signal log.