Struct InMemoryNotifier 

pub struct InMemoryNotifier { /* private fields */ }

In-process notifier backed by tokio::sync::Notify.

Useful for tests, single-process deployments where the worker and submitter share a runtime, or as a fallback when the cross-process notifier is unavailable.

Implementations

impl InMemoryNotifier

pub fn new() -> Self

Create a new notifier with no waiters.

Trait Implementations

impl Default for InMemoryNotifier

fn default() -> InMemoryNotifier

Returns the “default value” for a type.

impl Notifier for InMemoryNotifier

fn notify<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Signal that new work was added.

fn wait<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Block until a notification arrives. Spurious wake-ups are allowed.