broadcast

Oct 10, 2026

Changes in this version

+ type Cursor struct

+ Seq uint64

+ type Topic struct

+ func NewTopic[T any](capacity int) *Topic[T]

+ func (t *Topic[T]) Publish(msg T)

+ func (t *Topic[T]) Read(c *Cursor, dst []T) int