.

Signed-off-by: Keran Yang <yangkr920208@gmail.com>
numaproj-contrib · Sep 13, 2023 · a035c4b · a035c4b
1 parent 89e4a62
commit a035c4b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/nats/nats_test.go b/pkg/nats/nats_test.go
@@ -64,7 +64,7 @@ func Test_Single(t *testing.T) {
 
 	// Prepare a channel to receive messages
 	messageCh := make(chan sourcesdk.Message, 10)
-	ns.Read(ctx, TestReadRequest{count: 3, timeout: time.Second}, messageCh)
+	ns.Read(ctx, TestReadRequest{count: 5, timeout: time.Second}, messageCh)
 	assert.NoError(t, err)
 	assert.Equal(t, 3, len(messageCh))
 }