From a8199d5f70b15f226989b9dfbfefc5aee602126b Mon Sep 17 00:00:00 2001
From: Yordan Kinkov <yordan.kinkov@vereign.com>
Date: Mon, 20 Nov 2023 12:00:12 +0200
Subject: [PATCH] Return proper receiver error in events listener
---
internal/clients/event/client.go | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
diff --git a/internal/clients/event/client.go b/internal/clients/event/client.go
index 78e6ca6..6058795 100644
--- a/internal/clients/event/client.go
+++ b/internal/clients/event/client.go
@@ -34,11 +34,7 @@ func New(addr, subject string) (*Client, error) {
}
func (c *Client) Start(ctx context.Context) error {
- if err := c.events.StartReceiver(ctx, handler); err != nil {
- return err
- }
-
- return ctx.Err()
+ return c.events.StartReceiver(ctx, handler)
}
func (c *Client) Close(ctx context.Context) error {
--
GitLab