From 9945b2cb1e8b933c6ef374ec777de1f464b7410f Mon Sep 17 00:00:00 2001
From: Raphael Simon <simon.raphael@gmail.com>
Date: Sat, 12 Oct 2024 23:41:58 -0700
Subject: [PATCH] Fix tests

---
 streaming/options/options_test.go | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/streaming/options/options_test.go b/streaming/options/options_test.go
index e6604e3..e591ccf 100644
--- a/streaming/options/options_test.go
+++ b/streaming/options/options_test.go
@@ -159,7 +159,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -170,7 +170,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -181,7 +181,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      10,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -192,7 +192,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 				Topic:          "foo",
 			},
 		},
@@ -204,7 +204,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 				TopicPattern:   "foo*",
 			},
 		},
@@ -216,7 +216,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     10,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -227,7 +227,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "foo",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -238,7 +238,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    fmt.Sprintf("%d-0", date.UnixMilli()),
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -249,7 +249,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 				NoAck:          true,
 			},
 		},