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

fix connection status callbacks

Browse Source
This commit is contained in:
c9s 2021-12-30 17:23:27 +08:00
parent 4383823135
commit 26ff576727
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/bbgo/session.go
View File

@ -322,15 +322,13 @@ func (session *ExchangeSession) Init(ctx context.Context, environ *Environment)
// forward trade updates and order updates to the order executor
session.UserDataStream.OnTradeUpdate(session.OrderExecutor.EmitTradeUpdate)
session.UserDataStream.OnOrderUpdate(session.OrderExecutor.EmitOrderUpdate)
if len(session.Notifiability.notifiers) > 0 {
session.UserDataStream.OnDisconnect(func() {
session.Notifiability.Notify("session %s user data stream disconnected", session.Name)
})
session.UserDataStream.OnConnect(func() {
session.Notifiability.Notify("session %s user data stream connected", session.Name)
})
}
session.UserDataStream.OnDisconnect(func() {
session.Notifiability.Notify("session %s user data stream disconnected", session.Name)
})
session.UserDataStream.OnConnect(func() {
session.Notifiability.Notify("session %s user data stream connected", session.Name)
})
session.Account.BindStream(session.UserDataStream)