Struct MarketDataBus 

pub struct MarketDataBus { /* private fields */ }

Broadcast channel for normalized market-data events.

Example

let bus = MarketDataBus::new();
let mut rx = bus.subscribe();

// Producer side:
bus.publish(MarketDataEvent::Candle { ... });

// Consumer side:
while let Ok(event) = rx.recv().await {
    // ...
}

Implementations

impl MarketDataBus

pub fn new() -> MarketDataBus

Create a new bus with the default capacity.

pub fn with_capacity(capacity: usize) -> MarketDataBus

Create a new bus with an explicit channel capacity.

pub fn subscribe(&self) -> Receiver<MarketDataEvent>

Subscribe a new consumer. The returned receiver sees all events published after this call.

pub fn publish(&self, event: MarketDataEvent) -> usize

Publish an event. Returns the number of active subscribers that received it.

If the send fails (no subscribers) the event is silently dropped — this is the correct behaviour for a broadcast bus where the producer doesn’t care whether anyone is listening.

pub fn subscriber_count(&self) -> usize

Current number of subscribers.

Trait Implementations

impl Clone for MarketDataBus

fn clone(&self) -> MarketDataBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MarketDataBus

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for MarketDataBus

fn default() -> MarketDataBus

Returns the “default value” for a type.