From e84d21cb28eee0d9d40228a6d11289079f756cf8 Mon Sep 17 00:00:00 2001 From: James Hillyerd Date: Tue, 28 Feb 2023 10:25:16 -0800 Subject: [PATCH] events: Remove unnecessary go calls (#352) --- pkg/extension/luahost/lua_test.go | 4 ++-- pkg/message/manager.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/extension/luahost/lua_test.go b/pkg/extension/luahost/lua_test.go index 376def2..e372d33 100644 --- a/pkg/extension/luahost/lua_test.go +++ b/pkg/extension/luahost/lua_test.go @@ -87,7 +87,7 @@ func TestAfterMessageDeleted(t *testing.T) { Subject: "subj1", Size: 42, } - go extHost.Events.AfterMessageDeleted.Emit(msg) + extHost.Events.AfterMessageDeleted.Emit(msg) assertNotified(t, notify) } @@ -118,7 +118,7 @@ func TestAfterMessageStored(t *testing.T) { Subject: "subj1", Size: 42, } - go extHost.Events.AfterMessageStored.Emit(msg) + extHost.Events.AfterMessageStored.Emit(msg) assertNotified(t, notify) } diff --git a/pkg/message/manager.go b/pkg/message/manager.go index bd89d79..919c919 100644 --- a/pkg/message/manager.go +++ b/pkg/message/manager.go @@ -85,7 +85,7 @@ func (s *StoreManager) Deliver( // Emit message stored event. event := delivery.Meta event.ID = id - go s.ExtHost.Events.AfterMessageStored.Emit(&event) + s.ExtHost.Events.AfterMessageStored.Emit(&event) return id, nil }