From 571cbc958e4b8a5923347c4f9f59c3a9a0773445 Mon Sep 17 00:00:00 2001 From: Fred Carle Date: Thu, 27 Jun 2024 13:08:45 -0400 Subject: [PATCH] add comment --- tests/integration/p2p.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/tests/integration/p2p.go b/tests/integration/p2p.go index 9e5a5314af..4a57ac7a1a 100644 --- a/tests/integration/p2p.go +++ b/tests/integration/p2p.go @@ -294,6 +294,7 @@ func configureReplicator( Info: targetNode.PeerInfo(), }) if err == nil { + // wait for the replicator setup to complete <-sub.Message() } @@ -317,6 +318,7 @@ func deleteReplicator( Info: targetNode.PeerInfo(), }) if err == nil { + // wait for the replicator setup to complete <-sub.Message() } require.NoError(s.t, err) @@ -405,6 +407,7 @@ func subscribeToCollection( err = n.AddP2PCollections(s.ctx, schemaRoots) if err == nil { + // wait for the p2p collection setup to complete <-sub.Message() } @@ -442,6 +445,7 @@ func unsubscribeToCollection( err = n.RemoveP2PCollections(s.ctx, schemaRoots) if err == nil { + // wait for the p2p collection setup to complete <-sub.Message() }