ftx: update kline event handling for #318

This commit is contained in:
TonyQ 2021-12-12 14:29:48 +08:00
parent 1aca9f75a0
commit 6915a0e573

View File

@ -170,7 +170,9 @@ func (s *Stream) pollKLines(ctx context.Context) {
if len(klines) > 0 {
// handle mutiple klines, get the latest one
s.EmitKLineClosed(klines[len(klines)-1])
kline := klines[len(klines)-1]
s.EmitKLine(kline)
s.EmitKLineClosed(kline)
}
}
}