Skip to main content

DispatchWorkerPool

liminal::aion::dispatch

Trait DispatchWorkerPool 

Source 
pub trait DispatchWorkerPool:
    Debug
    + Send
    + Sync {
    // Required method
    fn workers_for(
        &self,
        channel_name: &ChannelName,
        request: &ActivityRequest,
    ) -> Result<Vec<DispatchWorker>, AionSurfaceError>;
}
Expand description

Supplies the current task queue subscriber snapshot.

Required Methods§

Source

fn workers_for( &self, channel_name: &ChannelName, request: &ActivityRequest, ) -> Result<Vec<DispatchWorker>, AionSurfaceError>

Returns workers currently subscribed to the dispatch channel.

§Errors

Returns an error if the subscriber snapshot cannot be loaded.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§