use crate::{aggregation::TradeTradeTimestamp, instrument::InstrumentSpec};
#[allow(unused_variables)]
pub trait MarketDataStream<IS: InstrumentSpec> {
fn trades_stream<'a>(
&mut self,
just_added: impl ExactSizeIterator<Item = &'a TradeTradeTimestamp<IS>> + Clone,
) -> impl Future<Output = ()>
where
IS: 'a,
{
async {}
}
}