diff --git a/internal/clients/event/client.go b/internal/clients/event/client.go index 9c5653d22543dc7eaa16a5a932d16a0709c57833..78e6ca6d38c0853975791a995f0cd22bce88d413 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 {