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

parse event from the binance private stream

Browse Source
This commit is contained in:
c9s 2020-06-29 03:11:05 +08:00
parent 338d2443b9
commit 4cd96360b3
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
bbgo/binance_exchange.go
View File

@ -82,8 +82,8 @@ func (s *PrivateStream) Connect(ctx context.Context) error {
return nil return nil
} }
func (s *PrivateStream) Read(ctx context.Context, messages chan []byte) { func (s *PrivateStream) Read(ctx context.Context, eventC chan interface{}) {
defer close(messages) defer close(eventC)
ticker := time.NewTicker(1 * time.Minute) ticker := time.NewTicker(1 * time.Minute)
defer ticker.Stop() defer ticker.Stop()
@ -112,7 +112,14 @@ func (s *PrivateStream) Read(ctx context.Context, messages chan []byte) {
} }
log.Debugf("[binance] recv: %s", message) log.Debugf("[binance] recv: %s", message)
messages <- message
e, err := ParseBinanceEvent(string(message))
if err != nil {
log.WithError(err).Errorf("[binance] event parse error")
continue
}
eventC <- e
} }
} }
} }