removed old code
This commit is contained in:
parent
193feac230
commit
394174a244
@ -641,44 +641,4 @@ impl ExchangeManager {
|
|||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
// async fn update_position_managers(&mut self, tick: u64) -> Result<OptionUpdate, BoxError> {
|
|
||||||
// let mut res_events = Vec::new();
|
|
||||||
// let mut res_messages = Vec::new();
|
|
||||||
//
|
|
||||||
// let mut futures: FuturesUnordered<_> = self
|
|
||||||
// .pair_managers
|
|
||||||
// .iter_mut()
|
|
||||||
// .map(|x| x.position_manager.update(tick))
|
|
||||||
// .collect();
|
|
||||||
//
|
|
||||||
// while let Some(future_result) = futures.next().await {
|
|
||||||
// let (opt_events, opt_messages) = future_result?;
|
|
||||||
//
|
|
||||||
// if let Some(events) = opt_events {
|
|
||||||
// res_events.extend(events);
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// if let Some(messages) = opt_messages {
|
|
||||||
// res_messages.extend(messages);
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// Ok((
|
|
||||||
// (!res_events.is_empty()).then_some(res_events),
|
|
||||||
// (!res_messages.is_empty()).then_some(res_messages),
|
|
||||||
// ))
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// async fn update_price_managers(&mut self, tick: u64) -> Result<OptionUpdate, BoxError> {
|
|
||||||
// let mut futures: FuturesUnordered<_> = self
|
|
||||||
// .pair_managers
|
|
||||||
// .iter_mut()
|
|
||||||
// .map(|x| x.price_manager.update(tick))
|
|
||||||
// .collect();
|
|
||||||
//
|
|
||||||
// while let Some(x) = futures.next().await {}
|
|
||||||
//
|
|
||||||
// Ok((None, None))
|
|
||||||
// }
|
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user