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

types: exit ping worker when error is happened

Browse Source
This commit is contained in:
c9s 2023-08-02 14:07:35 +08:00
parent 04da8fded7
commit e61db95bd8
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/types/stream.go
View File

@ -274,6 +274,7 @@ func (s *StandardStream) ping(ctx context.Context, conn *websocket.Conn, cancel
if err := conn.WriteControl(websocket.PingMessage, nil, time.Now().Add(writeTimeout)); err != nil {
log.WithError(err).Error("ping error", err)
s.Reconnect()
return
}
}
}
@ -306,6 +307,7 @@ func (s *StandardStream) Connect(ctx context.Context) error {
}
// start one re-connector goroutine with the base context
// reconnector goroutine does not exit when the connection is closed
go s.reconnector(ctx)
s.EmitStart()