This commit is contained in:
Dax Raad
2025-05-19 15:43:14 -04:00
parent 17ce46a0c7
commit f787ce1273
18 changed files with 188 additions and 498 deletions
+12
View File
@@ -182,6 +182,18 @@ to assist developers in writing, debugging, and understanding code directly from
}
}()
evts, err := app.Client.Event(ctx)
if err != nil {
slog.Error("Failed to subscribe to events", "error", err)
return err
}
go func() {
for item := range evts {
program.Send(item)
}
}()
// Cleanup function for when the program exits
cleanup := func() {
// Cancel subscriptions first