container, k8s: break intead of returning immediately
This commit is contained in:
parent
a9bf3cfb40
commit
81329e08a7
|
@ -633,7 +633,7 @@ func (eth *ethereum) WaitForBalances(addrs []common.Address, duration ...time.Du
|
||||||
var err error
|
var err error
|
||||||
for i := 0; i < len(addrs); i++ {
|
for i := 0; i < len(addrs); i++ {
|
||||||
if err = <-errc; err != nil {
|
if err = <-errc; err != nil {
|
||||||
return err
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
|
|
|
@ -322,7 +322,7 @@ func (eth *ethereum) WaitForBalances(addrs []common.Address, duration ...time.Du
|
||||||
var err error
|
var err error
|
||||||
for i := 0; i < len(addrs); i++ {
|
for i := 0; i < len(addrs); i++ {
|
||||||
if err = <-errc; err != nil {
|
if err = <-errc; err != nil {
|
||||||
return err
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
|
|
|
@ -78,7 +78,7 @@ func executeInParallel(fns ...func() error) error {
|
||||||
var err error
|
var err error
|
||||||
for i := 0; i < len(fns); i++ {
|
for i := 0; i < len(fns); i++ {
|
||||||
if err = <-errc; err != nil {
|
if err = <-errc; err != nil {
|
||||||
return err
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
|
|
Loading…
Reference in New Issue