Struct ManualWorker 

pub struct ManualWorker { /* private fields */ }

Manual single-step worker for tests (no background task).

Use BosonBuilder::build_manual to obtain one alongside Boson. Call try_run_next to claim and execute at most one queued job — useful in unit tests and the task_macro example.

Example

use std::sync::Arc;

use boson_backend_mem::MemQueueBackend;
use boson_core::{ExecutionContext, JsonExecutionContextFactory};
use boson_macros::task;
use boson_runtime::{configure, Boson, ManualWorker};

#[task(name = "ping")]
async fn ping(_ctx: Box<dyn ExecutionContext>) -> boson_core::Result<()> {
    Ok(())
}

let (boson, manual) = Boson::builder()
    .queue_backend(Arc::new(MemQueueBackend::new()))
    .execution_context_factory(JsonExecutionContextFactory)
    .auto_registry()
    .build_manual()?;
configure(boson);

Ping::send_with(serde_json::json!({"System": {}}), PingParams {}).await?;
assert!(manual.try_run_next().await); // runs the handler once

Implementations

impl ManualWorker

pub fn new( backend: Arc<dyn QueueBackend>, registry: Arc<TaskRegistry>, identity: Arc<dyn ExecutionContextFactory>, worker: WorkerSettings, ) -> Self

Create a worker that can be driven step-by-step in tests.

pub async fn try_run_next(&self) -> bool

Process at most one job across all pools.