feature: split writer to pipeline

awakari · Aug 1, 2023 · 9fb05e1 · 9fb05e1
1 parent 67881a7
commit 9fb05e1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/test/e2e_test.go b/test/e2e_test.go
@@ -39,7 +39,7 @@ func Test_MessageDelivery(t *testing.T) {
 		subIds = append(subIds, subId)
 	}
 	//
-	//time.Sleep(100 * time.Second) // wait for the cond/sub cache entries expiration
+	time.Sleep(100 * time.Second) // wait for the cond/sub cache entries expiration
 	//
 	var msgsWriter model.Writer[*pb.CloudEvent]
 	msgsWriter, err = client.OpenMessagesWriter(groupIdCtx, "test-user-1")
@@ -97,7 +97,7 @@ func Test_MessageDelivery(t *testing.T) {
 	for k, c := range cases {
 		t.Run(k, func(t *testing.T) {
 			//
-			ctx, cancel := context.WithTimeout(context.TODO(), 50*time.Second)
+			ctx, cancel := context.WithTimeout(context.TODO(), 1*time.Minute)
 			defer cancel()
 			var msgsReader model.Reader[[]*pb.CloudEvent]
 			msgsReader, err = client.OpenMessagesReader(ctx, "test-user-0", c.subId, 4)