Struct Subscribers 

pub struct Subscribers<T: ?Sized + Send + Sync + 'static> { /* private fields */ }

A list of subscribers held as weak references.

This type is useful for implementing observer/listener patterns where:

• Subscribers register to receive notifications
• The registry doesn’t keep subscribers alive (weak references)
• Dead subscribers are cleaned up during registration

Example

use std::sync::Arc;

use scion_stack::types::Subscribers;

trait EventReceiver: Send + Sync {
    fn on_event(&self, data: &str);
}

struct MyReceiver;
impl EventReceiver for MyReceiver {
    fn on_event(&self, data: &str) {
        println!("Received: {}", data);
    }
}

let subscribers: Subscribers<dyn EventReceiver> = Subscribers::new();
let receiver: Arc<dyn EventReceiver> = Arc::new(MyReceiver);

subscribers.register(receiver.clone());

subscribers.for_each(|r| r.on_event("hello"));
drop(receiver);

Implementations

impl<T: ?Sized + Send + Sync + 'static> Subscribers<T>

pub fn new() -> Self

Creates a new empty set of subscribers.

pub fn register(&self, subscriber: Arc<T>)

Register a subscriber. The subscriber is held as a weak reference and will be automatically removed when dropped.

pub fn for_each(&self, f: impl FnMut(&T))

Execute a closure for each live subscriber.

Trait Implementations

impl<T: ?Sized + Send + Sync + 'static> Clone for Subscribers<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: ?Sized + Send + Sync + 'static> Default for Subscribers<T>

fn default() -> Self

Returns the “default value” for a type.