fix: pull will sleep at frist

This commit is contained in:
langhuihui
2023-09-18 17:15:43 +08:00
parent ff6d3a7bfc
commit efc749624d
+1 -1
View File
@@ -55,7 +55,7 @@ func (pub *Puller) startPull(puller IPuller) {
}
}()
puber := puller.GetPublisher()
startTime := time.Now()
var startTime time.Time
for puller.Info("start pull"); puller.Reconnect(); puller.Warn("restart pull") {
if time.Since(startTime) < 5*time.Second {
time.Sleep(5 * time.Second)