xmaker: bind price solver with market data stream

c9s · Sep 27, 2024 · 61c4c4d · 61c4c4d
1 parent 93334b5
commit 61c4c4d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/strategy/xmaker/strategy.go b/pkg/strategy/xmaker/strategy.go
@@ -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()