diff --git a/replicator/replicator_test.go b/replicator/replicator_test.go
index d655408..8cda71d 100644
--- a/replicator/replicator_test.go
+++ b/replicator/replicator_test.go
@@ -61,7 +61,7 @@ func TestReplicatorStream(t *testing.T) {
 			go func(t *testing.T) {
 				defer wg.Done()
 				if err := replicator.Stream(ctx); err != nil && !errors.Is(err, ctx.Err()) {
-					t.Fatal(err)
+					t.Error(err)
 				}
 			}(t)
 			if c.during != nil {