Struct Subscribers

pub struct Subscribers<StateT: AgentState = Value, FwdPropsT: FwdProps = Value> { /* private fields */ }

Wrapper for subscriber implementations.

Facilitates easy casting to and from types that implement AgentSubscriber.

Examples

// Create from a single subscriber
let subscriber = MySubscriber;
let subscribers = Subscribers::from_subscriber(subscriber);

// Create from multiple subscribers
let subscriber_vec = vec![MySubscriber, MySubscriber];
let subscribers = Subscribers::from_iter(subscriber_vec);

// Create from pre-wrapped Arc subscribers
let arc_subscribers: Vec<Arc<dyn AgentSubscriber>> = vec![
    Arc::new(MySubscriber)
];
let subscribers = Subscribers::new(arc_subscribers);

Implementations

impl<StateT: AgentState, FwdPropsT: FwdProps> Subscribers<StateT, FwdPropsT>

pub fn new( subscribers: Vec<Arc<dyn AgentSubscriber<StateT, FwdPropsT>>>, ) -> Self

pub fn from_subscriber<T>(subscriber: T) -> Self

where T: AgentSubscriber<StateT, FwdPropsT> + 'static,

Creates a new Subscribers collection from a single subscriber

Trait Implementations

impl<StateT: Clone + AgentState, FwdPropsT: Clone + FwdProps> Clone for Subscribers<StateT, FwdPropsT>

fn clone(&self) -> Subscribers<StateT, FwdPropsT>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<StateT, FwdPropsT, T> FromIterator<T> for Subscribers<StateT, FwdPropsT>

where StateT: AgentState, FwdPropsT: FwdProps, T: AgentSubscriber<StateT, FwdPropsT> + 'static,

fn from_iter<I: IntoIterator<Item = T>>(iter: I) -> Self

Creates a value from an iterator.

impl<'a, StateT, FwdPropsT> IntoIterator for &'a Subscribers<StateT, FwdPropsT>

where StateT: AgentState, FwdPropsT: FwdProps,

type Item = &'a Arc<dyn AgentSubscriber<StateT, FwdPropsT>>

The type of the elements being iterated over.

type IntoIter = Iter<'a, Arc<dyn AgentSubscriber<StateT, FwdPropsT>>>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<StateT, FwdPropsT> IntoSubscribers<StateT, FwdPropsT> for Subscribers<StateT, FwdPropsT>

where StateT: AgentState, FwdPropsT: FwdProps,

fn into_subscribers(self) -> Subscribers<StateT, FwdPropsT>