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

fix(ftx): rename to pollKLines()

Browse Source
This commit is contained in:
Jui-Nan Lin 2021-05-24 14:21:40 +08:00
parent 239d55ce33
commit a7a141c3ea
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -127,7 +127,7 @@ func (s *Stream) Subscribe(channel types.Channel, symbol string, option types.Su
} else if channel == types.KLineChannel { } else if channel == types.KLineChannel {
// FTX does not support kline channel, do polling // FTX does not support kline channel, do polling
go s.subscribeKLine(symbol, option) go s.pollKLines(symbol, option)
} else { } else {
panic("only support book/kline channel now") panic("only support book/kline channel now")
} }
@ -147,7 +147,7 @@ func (s *Stream) handleChannelKlineMessage(ctx context.Context) {
} }
} }
func (s *Stream) subscribeKLine(symbol string, option types.SubscribeOptions) { func (s *Stream) pollKLines(symbol string, option types.SubscribeOptions) {
interval := types.Interval(option.Interval) interval := types.Interval(option.Interval)
if !isIntervalSupportedInKLine(interval) { if !isIntervalSupportedInKLine(interval) {
logger.Errorf("not supported kline interval %s", option.Interval) logger.Errorf("not supported kline interval %s", option.Interval)