diff options
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/client/event.go | 17 |
1 files changed, 6 insertions, 11 deletions
diff --git a/pkg/client/event.go b/pkg/client/event.go index a6d7798fa..677eb424b 100644 --- a/pkg/client/event.go +++ b/pkg/client/event.go @@ -20,18 +20,18 @@ type EventMessage struct { func (c *Client) Event(ctx context.Context) (<-chan any, error) { events := make(chan any) - req, err := http.NewRequestWithContext(ctx, "GET", c.Server+"/event", nil) + req, err := http.NewRequestWithContext(ctx, "GET", c.Server+"event", nil) + if err != nil { + return nil, err + } + + resp, err := http.DefaultClient.Do(req) if err != nil { return nil, err } go func() { defer close(events) - - resp, err := http.DefaultClient.Do(req) - if err != nil { - return - } defer resp.Body.Close() scanner := bufio.NewScanner(resp.Body) @@ -47,11 +47,6 @@ func (c *Client) Event(ctx context.Context) (<-chan any, error) { eventTemplate, exists := EventMap[eventMsg.Type] if !exists { - select { - case events <- eventMsg: - case <-ctx.Done(): - return - } continue } |