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