Struct ora_test::TestWorkerPool

pub struct TestWorkerPool { /* private fields */ }

A worker pool that can be used to test worker implementations.

Implementations

impl TestWorkerPool

pub fn new() -> Self

Create a new test worker pool.

pub fn register_worker( &mut self, worker: Arc<dyn RawWorker + Send + Sync> ) -> &mut Self

Add a worker to the test pool.

Panics

Panics if a worker with a matching WorkerSelector already exists.

pub fn spawn_task<T>( &mut self, task: TaskDefinition<T> ) -> Option<TaskHandle<T>>where T: Send + 'static,

Spawn a task onto the worker pool, immediately run it with a registered and return a TaskHandle for it.

It returns None if there are no suitable workers registered.

Panics

Panics if not called inside a tokio runtime.

Trait Implementations

impl Debug for TestWorkerPool

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

Formats the value using the given formatter.

impl Default for TestWorkerPool

fn default() -> TestWorkerPool

Returns the “default value” for a type.