Sleep less to avoid timeouts

Signed-off-by: Doug Davis <[email protected]>
cloudevents · Oct 24, 2023 · 13825ba · 13825ba
1 parent 29fbc28
commit 13825ba
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/test/integration/kafka_sarama_binding/kafka_test.go b/test/integration/kafka_sarama_binding/kafka_test.go
@@ -104,7 +104,7 @@ func testSenderReceiver(t testing.TB) (func(), bindings.Sender, bindings.Receive
 
 	// Not perfect but we need to give OpenInbound() as chance to start
 	// as it's a race condition. I couldn't find something on 'p' to wait for
-	time.Sleep(15 * time.Second)
+	time.Sleep(6 * time.Second)
 
 	return func() {
 		require.NoError(t, p.Close(context.TODO()))

diff --git a/v2/client/test/test.go b/v2/client/test/test.go
@@ -31,7 +31,7 @@ func SendReceive(t *testing.T, protocolFactory func() interface{}, in event.Even
 	wg.Add(2)
 
 	// Give time for Kafka client protocol to get setup
-	time.Sleep(5 * time.Second)
+	time.Sleep(2 * time.Second)
 
 	go func() {
 		ctx, cancel := context.WithCancel(context.TODO())
@@ -54,7 +54,7 @@ func SendReceive(t *testing.T, protocolFactory func() interface{}, in event.Even
 	}()
 
 	// Give time for the receiever to start
-	time.Sleep(5 * time.Second)
+	time.Sleep(2 * time.Second)
 
 	go func() {
 		defer wg.Done()