Struct MarketFeedService 

pub struct MarketFeedService { /* private fields */ }

Drives a MarketSource under supervisor control.

The wrapper does not interact with the bus directly — the source’s run method is expected to publish events to whatever bus it was constructed with. This service just makes the source restartable and drop-safe under the supervisor’s cancellation contract.

Implementations

impl MarketFeedService

pub fn new(source: Arc<dyn MarketSource>) -> Self

Wrap a MarketSource into a TradingService.

Trait Implementations

impl TradingService for MarketFeedService

fn name(&self) -> &str

Unique service name for logs, metrics, and supervisor identification.

fn restart_policy(&self) -> RestartPolicy

When should the supervisor restart this service on exit?

fn run<'life0, 'async_trait>( &'life0 self, cancel: CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Main execution loop. Must honour the cancellation token.