Make a few comments a bit clearer

Signed-off-by: Doug Davis <dug@microsoft.com>
cloudevents · Oct 29, 2023 · ecead5c · ecead5c
1 parent 5f8d04b
commit ecead5c
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/test/integration/mqtt_paho/mqtt_test.go b/test/integration/mqtt_paho/mqtt_test.go
@@ -38,8 +38,9 @@ func TestSendEvent(t *testing.T) {
 		eventChan := make(chan receiveEvent)
 		defer close(eventChan)
 
-		// Used to try to make sure the receiver is ready before we start to
-		// send events
+		// 'wait' is used to ensure that we at least wait until the Receiver
+		// thread starts. We'll then use a 'sleep' (hoping) that waits until
+		// the Receiver itself is ready
 		wait := make(chan bool)
 
 		go func() {

diff --git a/v2/protocol/test/test.go b/v2/protocol/test/test.go
@@ -25,8 +25,9 @@ func SendReceive(t *testing.T, ctx context.Context, in binding.Message, s protoc
 	wg := sync.WaitGroup{}
 	wg.Add(2)
 
-	// Used to try to make sure the receiver is ready before we start to
-	// send events
+	// 'wait' is used to ensure that we at least wait until the Receiver
+	// thread starts. We'll then use a 'sleep' (hoping) that waits until
+	// the Receiver itself is ready
 	wait := make(chan bool)
 
 	go func() {