diff options
| author | Dax Raad <[email protected]> | 2025-05-19 16:07:01 -0400 |
|---|---|---|
| committer | Dax Raad <[email protected]> | 2025-05-26 12:40:17 -0400 |
| commit | fa8a46326afa2d7fbb592542abf243f248cb5992 (patch) | |
| tree | 96b7b0ef2054551ad1b8b3a48ce35c8f6f79ee5a /pkg | |
| parent | 652429377b99085d686d6b907c2f550c304e6b98 (diff) | |
| download | opencode-fa8a46326afa2d7fbb592542abf243f248cb5992.tar.gz opencode-fa8a46326afa2d7fbb592542abf243f248cb5992.zip | |
codegen
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 } |
