vrr/opencode
2
0
Fork 0
mirror of https://github.com/anomalyco/opencode.git synced 2026-05-06 00:12:11 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 18

feat: better logs page

Browse source
This commit is contained in:
adamdottv 2025-05-06 14:22:37 -05:00
parent e387b1f16c
commit b638dafe5f
No known key found for this signature in database
GPG key ID: 9CB48779AF150E75
8 changed files with 280 additions and 36 deletions
Download patch file Download diff file Expand all files Collapse all files

18
internal/pubsub/broker.go
View file

@ -5,7 +5,7 @@ import (
"sync"
)
const bufferSize = 64
const bufferSize = 1000
type Broker[T any] struct {
subs map[chan Event[T]]struct{}
@ -115,7 +115,23 @@ func (b *Broker[T]) Publish(t EventType, payload T) {
for _, sub := range subscribers {
select {
case sub <- event:
// Successfully sent
case <-b.done:
// Broker is shutting down
return
default:
// Channel is full, but we don't want to block
// Log this situation or consider other strategies
// For now, we'll create a new goroutine to ensure delivery
go func(ch chan Event[T], evt Event[T]) {
select {
case ch <- evt:
// Successfully sent
case <-b.done:
// Broker is shutting down
return
}
}(sub, event)
}
}
}