Update itests/kit/rpc.go
Co-authored-by: Anton Evangelatov <anton.evangelatov@gmail.com>
This commit is contained in:
parent
5f0489ace0
commit
c34ade9ffb
@ -44,11 +44,9 @@ func waitUpTo(fn func(), waitTime time.Duration, errMsg string) {
|
|||||||
close(ch)
|
close(ch)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
timer := time.NewTimer(waitTime)
|
|
||||||
defer timer.Stop()
|
|
||||||
select {
|
select {
|
||||||
case <-ch:
|
case <-ch:
|
||||||
case <-timer.C:
|
case <-time.After(waitTime):
|
||||||
fmt.Println(errMsg)
|
fmt.Println(errMsg)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user