diff --git a/core_test.go b/core_test.go
index a8e70ba..f3dc4d3 100644
--- a/core_test.go
+++ b/core_test.go
@@ -352,7 +352,7 @@ func TestForEach(t *testing.T) {
 					t.Errorf("early exit did not happen")
 				}
 
-				time.Sleep(1 * time.Second)
+				time.Sleep(2 * time.Second)
 				th.ExpectDrainedChan(t, in)
 			})
 		})
@@ -379,7 +379,7 @@ func TestForEach(t *testing.T) {
 				}
 
 				// wait until it drained
-				time.Sleep(1 * time.Second)
+				time.Sleep(2 * time.Second)
 				th.ExpectDrainedChan(t, in)
 			})
 		})
diff --git a/internal/core/loops_test.go b/internal/core/loops_test.go
index 3e9bfcd..bb115cb 100644
--- a/internal/core/loops_test.go
+++ b/internal/core/loops_test.go
@@ -105,7 +105,7 @@ func TestBreakable(t *testing.T) {
 		for x := range in1 {
 			if x == 100 {
 				earlyExit()
-				time.Sleep(1 * time.Second) // give Break some time to react and drain
+				time.Sleep(2 * time.Second) // give Break some time to react and drain
 			}
 
 			if x > maxSeen {
diff --git a/wrap_test.go b/wrap_test.go
index 21af4ba..bd1f0d4 100644
--- a/wrap_test.go
+++ b/wrap_test.go
@@ -57,7 +57,7 @@ func TestFromSlice(t *testing.T) {
 		th.ExpectSlice(t, outSlice, inSlice[:15])
 		th.ExpectError(t, err, "err15")
 
-		time.Sleep(1 * time.Second)
+		time.Sleep(2 * time.Second)
 		th.ExpectDrainedChan(t, in)
 	})
 }