Struct AsyncHarness 

pub struct AsyncHarness { /* private fields */ }

Executes handlers the way production does, minus the polling.

let harness = AsyncHarness::builder()
    .command(SendEmailHandler::__handler_entry(&container))
    .container(container)
    .build();

harness.execute(&SendEmail { to: "ada@example.com".into() })
    .await
    .assert_succeeded();

Implementations

impl AsyncHarness

pub fn builder() -> AsyncHarnessBuilder

pub fn container(&self) -> &Container

The container handlers resolve from — register their dependencies here before building.

pub async fn execute<C: CommandData + Serialize>( &self, command: &C, ) -> FinishedJob

Enqueue and run one command through the real runner, returning the finished job.

Panics

If no handler is registered for the command. A test that runs a command nothing handles is testing nothing, and in production that is a boot-time misconfiguration rather than a runtime branch.

pub async fn execute_named( &self, command_name: &str, payload: Value, ) -> FinishedJob

AsyncHarness::execute with the command named directly — for a cron’s command, or a payload built as raw JSON.

pub async fn run_cron(&self, command_name: &str) -> FinishedJob

Run one cron handler’s body immediately — the tick without the clock.

pub async fn jobs(&self) -> Vec<Job>

Every job the harness has run, oldest first.