Struct SourceRegistry 

pub struct SourceRegistry { /* private fields */ }

Maps natural domain keys to DataSource values.

Single World resource supporting any number of key types via type erasure. Each key type K gets its own internal HashMap<K, DataSource>. The TypeId dispatch is one hash lookup to find the right inner map — cold path only.

Any Hash + Eq + Send + 'static type works as a key — no trait to implement, no macro to invoke. Newtypes, enums, and tuples all work out of the box.

Example

// Setup
let src = notify.register_source();
registry.insert(InstrumentId("BTC"), src);

// Runtime lookup (cold path — from event handler)
let src = registry.get(&InstrumentId("BTC")).unwrap();
notify.register(|t| ctx, step, reg).subscribe(src);

// Hot path — DataSource pre-resolved, no registry involvement
notify.mark(src);

Implementations

impl SourceRegistry

pub fn new() -> Self

Create an empty registry.

pub fn insert<K: Hash + Eq + Send + 'static>( &mut self, key: K, source: DataSource, )

Map a typed key to a DataSource.

Overwrites any previous mapping for this key.

pub fn get<K: Hash + Eq + Send + 'static>(&self, key: &K) -> Option<DataSource>

Look up a DataSource by typed key.

Returns None if the key is not registered.

pub fn remove<K: Hash + Eq + Send + 'static>( &mut self, key: &K, ) -> Option<DataSource>

Remove a key mapping. Returns the DataSource so the caller can also call ReactorNotify::remove_source to free the slot.

pub fn contains<K: Hash + Eq + Send + 'static>(&self, key: &K) -> bool

Returns true if the key is mapped.

Trait Implementations

impl Default for SourceRegistry

fn default() -> SourceRegistry

Returns the “default value” for a type.

impl Resource for SourceRegistry