wait repli

octu0 · Jun 27, 2022 · 66c5b2d · 66c5b2d
1 parent 11dcf96
commit 66c5b2d
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/repli/stream_test.go b/repli/stream_test.go
@@ -1815,13 +1815,17 @@ func testRepliStreamReciverRepliDestinationBehindSourceProcessing(t *testing.T)
 		Size:   s4,
 	})
 
+	time.Sleep(100 * time.Millisecond)
+
 	if err := r.Stop(); err != nil {
 		t.Errorf("no error %+v", err)
 	}
 	if err := e.Stop(); err != nil {
 		t.Errorf("no error %+v", err)
 	}
 
+	time.Sleep(100 * time.Millisecond)
+
 	if src.countFileIds != 1 {
 		t.Errorf("fist access")
 	}