From 47c6e3949fe5bb1dd3f86ed3890188beda77d053 Mon Sep 17 00:00:00 2001
From: Yordan Kinkov <yordan.kinkov@vereign.com>
Date: Mon, 20 Nov 2023 10:39:57 +0200
Subject: [PATCH] Add proper event listener logic
---
internal/clients/event/client.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/internal/clients/event/client.go b/internal/clients/event/client.go
index 9c5653d..78e6ca6 100644
--- a/internal/clients/event/client.go
+++ b/internal/clients/event/client.go
@@ -34,11 +34,11 @@ func New(addr, subject string) (*Client, error) {
}
func (c *Client) Start(ctx context.Context) error {
- for {
- if err := c.events.StartReceiver(ctx, handler); err != nil {
- return err
- }
+ if err := c.events.StartReceiver(ctx, handler); err != nil {
+ return err
}
+
+ return ctx.Err()
}
func (c *Client) Close(ctx context.Context) error {
--
GitLab