explicit pair_statuses creation
This commit is contained in:
parent
a029390c38
commit
4d3a2ea892
@ -8,6 +8,7 @@ use tokio::time::delay_for;
|
|||||||
|
|
||||||
use crate::connectors::Connector;
|
use crate::connectors::Connector;
|
||||||
use crate::currency::{Symbol, SymbolPair};
|
use crate::currency::{Symbol, SymbolPair};
|
||||||
|
use crate::events::EventKind;
|
||||||
use crate::pairs::PairStatus;
|
use crate::pairs::PairStatus;
|
||||||
use crate::strategy::Strategy;
|
use crate::strategy::Strategy;
|
||||||
use crate::ticker::Ticker;
|
use crate::ticker::Ticker;
|
||||||
@ -28,14 +29,16 @@ impl<'a> BfxBot<'a> {
|
|||||||
quote: Symbol,
|
quote: Symbol,
|
||||||
tick_duration: Duration,
|
tick_duration: Duration,
|
||||||
) -> Self {
|
) -> Self {
|
||||||
BfxBot {
|
let pair_statuses = trading_symbols
|
||||||
connector: Box::new(connector),
|
|
||||||
ticker: Ticker::new(tick_duration),
|
|
||||||
pair_statuses: trading_symbols
|
|
||||||
.iter()
|
.iter()
|
||||||
.map(|x| SymbolPair::new(quote.clone(), x.clone()))
|
.map(|x| SymbolPair::new(quote.clone(), x.clone()))
|
||||||
.map(|x| PairStatus::new(x, 1, None))
|
.map(|x| PairStatus::new(x, 1, None))
|
||||||
.collect(),
|
.collect();
|
||||||
|
|
||||||
|
BfxBot {
|
||||||
|
connector: Box::new(connector),
|
||||||
|
ticker: Ticker::new(tick_duration),
|
||||||
|
pair_statuses,
|
||||||
quote,
|
quote,
|
||||||
trading_symbols,
|
trading_symbols,
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user