emit start callback for backtest

This commit is contained in:
c9s 2021-05-08 00:43:53 +08:00
parent 3501e8f5fd
commit 61ad2b6567

View File

@ -53,6 +53,7 @@ func (s *Stream) Connect(ctx context.Context) error {
go func() {
s.EmitConnect()
s.EmitStart()
klineC, errC := s.exchange.srv.QueryKLinesCh(s.exchange.startTime, s.exchange.endTime, s.exchange, symbols, intervals)
numKlines := 0