From a035c4b04c7bcb4dfed27cc130e1ef053fcefa62 Mon Sep 17 00:00:00 2001 From: Keran Yang Date: Wed, 13 Sep 2023 16:53:21 -0400 Subject: [PATCH] . Signed-off-by: Keran Yang --- pkg/nats/nats_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/nats/nats_test.go b/pkg/nats/nats_test.go index a212d9a..ff297ac 100644 --- 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)) }