lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-14 19:13:52 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

xmaker: bind price solver with market data stream

Browse Source
This commit is contained in:
c9s 2024-09-27 18:31:18 +08:00
parent e8c063c09b
commit be353c533b
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/strategy/xmaker/strategy.go
View File

@ -1398,7 +1398,6 @@ func (s *Strategy) CrossRun(
// initialize the price resolver
sourceMarkets := s.sourceSession.Markets()
s.priceSolver = pricesolver.NewSimplePriceResolver(sourceMarkets)
makerSession, ok := sessions[s.MakerExchange]
if !ok {
@ -1475,6 +1474,9 @@ func (s *Strategy) CrossRun(
})
}
s.priceSolver = pricesolver.NewSimplePriceResolver(sourceMarkets)
s.priceSolver.BindStream(s.sourceSession.MarketDataStream)
s.sourceSession.MarketDataStream.OnKLineClosed(types.KLineWith(s.Symbol, types.Interval1m, func(k types.KLine) {
s.priceSolver.Update(k.Symbol, k.Close)
feeToken := s.sourceSession.Exchange.PlatformFeeCurrency()