lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-22 23:05:15 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

ftx: Separate the lastClosed record for different interval

Browse Source
This commit is contained in:
Lee 2022-01-15 05:12:45 +08:00
parent 8a3f1c4dba
commit f6c70bdfcb
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/exchange/ftx/stream.go
View File

@ -133,16 +133,16 @@ func (s *Stream) Subscribe(channel types.Channel, symbol string, option types.Su
func (s *Stream) pollKLines(ctx context.Context) {
lastClosed := time.Time{}
lastClosed := map[types.Interval]time.Time{}
// get current kline candle
for _, sub := range s.klineSubscriptions {
klines := getLast2KLine(s.exchange, ctx, sub.symbol, sub.interval)
if len(klines) > 0 {
// handle mutiple klines, get the latest one
if lastClosed.Unix() < klines[0].StartTime.Unix() {
if lastClosed[sub.interval].Unix() < klines[0].StartTime.Unix() {
s.EmitKLine(klines[0])
s.EmitKLineClosed(klines[0])
lastClosed = klines[0].StartTime.Time()
lastClosed[sub.interval] = klines[0].StartTime.Time()
}
if len(klines) > 1 {
@ -174,10 +174,10 @@ func (s *Stream) pollKLines(ctx context.Context) {
if len(klines) > 0 {
// handle mutiple klines, get the latest one
if lastClosed.Unix() < klines[0].StartTime.Unix() {
if lastClosed[sub.interval].Unix() < klines[0].StartTime.Unix() {
s.EmitKLine(klines[0])
s.EmitKLineClosed(klines[0])
lastClosed = klines[0].StartTime.Time()
lastClosed[sub.interval] = klines[0].StartTime.Time()
}
if len(klines) > 1 {