summaryrefslogtreecommitdiffhomepage
path: root/pkg
diff options
context:
space:
mode:
authorDax Raad <[email protected]>2025-05-19 16:07:01 -0400
committerDax Raad <[email protected]>2025-05-26 12:40:17 -0400
commitfa8a46326afa2d7fbb592542abf243f248cb5992 (patch)
tree96b7b0ef2054551ad1b8b3a48ce35c8f6f79ee5a /pkg
parent652429377b99085d686d6b907c2f550c304e6b98 (diff)
downloadopencode-fa8a46326afa2d7fbb592542abf243f248cb5992.tar.gz
opencode-fa8a46326afa2d7fbb592542abf243f248cb5992.zip
codegen
Diffstat (limited to 'pkg')
-rw-r--r--pkg/client/event.go17
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
}