Struct SubscriptionWorkerMap

pub struct SubscriptionWorkerMap { /* private fields */ }

A map of subscription processes which can be run as a stream.

Implementations

impl SubscriptionWorkerMap

pub fn new() -> Self

Create a new subscription collection.

pub fn insert<Repo, FrameService>( &mut self, repo: &Repo, config: impl Into<SubscriptionConfig>, service: FrameService, )

where Repo: EventRepo + Clone + Send + Sync + 'static, FrameService: Service<Frame> + Clone + Send + Sync + 'static, FrameService::Future: Send, <FrameService as Service<Frame>>::Response: Into<Frame>, <FrameService as Service<Frame>>::Error: Into<Frame>,

Insert a subscription process into the map using a config and a frame service. The subscription process will be started immediately, but won’t do anything until it is polled.

pub fn stream(self) -> impl Stream<Item = (String, Frame)>

Consume the process map and collect all the workers from it into a single stream.

Trait Implementations

impl Default for SubscriptionWorkerMap

fn default() -> Self

Returns the “default value” for a type.