diff --git a/dot/network/stream_manager_test.go b/dot/network/stream_manager_test.go
index c831f01144..19b1e0ae81 100644
--- a/dot/network/stream_manager_test.go
+++ b/dot/network/stream_manager_test.go
@@ -71,11 +71,11 @@ func TestStreamManager(t *testing.T) {
 
 	time.Sleep(cleanupStreamInterval * 2)
 	connsAToB := ha.Network().ConnsToPeer(hb.ID())
-	require.Equal(t, 1, len(connsAToB))
+	require.GreaterOrEqual(t, len(connsAToB), 1)
 	require.Equal(t, 0, len(connsAToB[0].GetStreams()))
 
 	connsBToA := hb.Network().ConnsToPeer(ha.ID())
-	require.Equal(t, 1, len(connsBToA))
+	require.GreaterOrEqual(t, len(connsBToA), 1)
 	require.Equal(t, 0, len(connsBToA[0].GetStreams()))
 }
 
@@ -91,12 +91,12 @@ func TestStreamManager_KeepStream(t *testing.T) {
 	smA.start()
 	smB.start()
 
-	time.Sleep(cleanupStreamInterval / 2)
+	time.Sleep(cleanupStreamInterval / 3)
 	connsAToB := ha.Network().ConnsToPeer(hb.ID())
-	require.Equal(t, 1, len(connsAToB))
+	require.GreaterOrEqual(t, len(connsAToB), 1)
 	require.Equal(t, 1, len(connsAToB[0].GetStreams()))
 
 	connsBToA := hb.Network().ConnsToPeer(ha.ID())
-	require.Equal(t, 1, len(connsBToA))
+	require.GreaterOrEqual(t, len(connsBToA), 1)
 	require.Equal(t, 1, len(connsBToA[0].GetStreams()))
 }