From 90fe296939a3ba7834187dd7c5c4da34a4fe4d14 Mon Sep 17 00:00:00 2001 From: miguelreiswildlife Date: Tue, 25 Jun 2024 12:30:00 -0300 Subject: [PATCH] Remove wait --- e2e/apns_e2e_test.go | 1 - extensions/apns/apns_message_handler.go | 2 -- 2 files changed, 3 deletions(-) diff --git a/e2e/apns_e2e_test.go b/e2e/apns_e2e_test.go index 11be309..87981d2 100644 --- a/e2e/apns_e2e_test.go +++ b/e2e/apns_e2e_test.go @@ -375,7 +375,6 @@ func (s *ApnsE2ETestSuite) TestConsumeMessagesBeforeExiting() { ctx, cancel := context.WithCancel(c) go p.Start(ctx) time.Sleep(wait) - time.Sleep(20 * time.Second) notificationsToSend := 30 diff --git a/extensions/apns/apns_message_handler.go b/extensions/apns/apns_message_handler.go index ccc8cba..856fb16 100644 --- a/extensions/apns/apns_message_handler.go +++ b/extensions/apns/apns_message_handler.go @@ -41,8 +41,6 @@ import ( "github.com/topfreegames/pusher/structs" ) -var apnsResMutex sync.Mutex - // pusherAPNSKafkaMessage is the notification format received in Kafka messages. type pusherAPNSKafkaMessage struct { ApnsID string