binance: emit disconnect

This commit is contained in:
c9s 2021-03-15 13:27:18 +08:00
parent 6d249cf83c
commit c95e712420

View File

@ -366,6 +366,8 @@ func (s *Stream) read(ctx context.Context) {
log.Info("websocket connection closed, going away") log.Info("websocket connection closed, going away")
} }
s.EmitDisconnect()
// reconnect // reconnect
for err != nil { for err != nil {
select { select {