apple_quant_algorithmic/backend/market_data_stream.rs
1use crate::{aggregation::TradeTradeTimestamp, instrument::InstrumentSpec};
2
3#[allow(unused_variables)]
4pub trait MarketDataStream<IS: InstrumentSpec> {
5 fn trades_stream<'a>(
6 &mut self,
7 just_added: impl ExactSizeIterator<Item = &'a TradeTradeTimestamp<IS>> + Clone,
8 ) -> impl Future<Output = ()>
9 where
10 IS: 'a,
11 {
12 async {}
13 }
14}