Struct ActivityRegistry 

pub struct ActivityRegistry { /* private fields */ }

Registry of typed activity handlers keyed by activity-type name.

Implementations

impl ActivityRegistry

pub fn new() -> Self

Creates an empty activity registry.

pub fn register_activity<Input, Output, Handler>( self, activity_type: impl Into<String>, handler: Handler, ) -> Result<Self, WorkerError>

where Input: Serialize + DeserializeOwned + Send + Sync + 'static, Output: Serialize + Send + Sync + 'static, Handler: for<'context> Fn(Input, &'context ActivityContext) -> HandlerFuture<'context, Output> + Send + Sync + 'static,

Registers one typed activity handler under an activity-type name.

Errors

Returns WorkerError::Registration when the name is already registered.

pub fn is_empty(&self) -> bool

Returns true when no activity handlers have been registered.

pub fn activity_types(&self) -> BTreeSet<String>

Returns the registered activity-type names in deterministic order.

Trait Implementations

impl ActivityDispatcher for ActivityRegistry

fn dispatch<'life0, 'async_trait>( &'life0 self, task: ActivityTask, context: ActivityContext, ) -> Pin<Box<dyn Future<Output = Result<DispatchOutcome, WorkerError>> + Send + 'async_trait>>

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

Executes one decoded activity task with the provided handler context.

fn activity_types(&self) -> BTreeSet<String>

Activity type names this dispatcher can serve.

impl Default for ActivityRegistry

fn default() -> ActivityRegistry

Returns the “default value” for a type.