This commit is contained in:
c9s 2020-07-13 01:55:16 +08:00
parent a9e25c08d7
commit 704c6eed96

View File

@ -158,6 +158,7 @@ func (s *PrivateStream) read(ctx context.Context, eventC chan interface{}) {
return return
default: default:
s.Subscriptions = nil
err = s.connect(ctx) err = s.connect(ctx)
time.Sleep(5 * time.Second) time.Sleep(5 * time.Second)
} }