watch

Aug 22, 2026

Changes in this version

type Hub

+ func (h *Hub[K, V]) WithBaseline(cur V) WatchOption[K, V]

+ type WatchOption func(*watchConfig[V])

Aug 4, 2026

Changes in this version

type Hub

+ func (h *Hub[K, V]) WatchAcross(initial V) *Receiver[K, V]

Aug 1, 2026

Changes in this version

type Receiver

+ func (rx *Receiver[K, V]) Peek() (gobus.Event[K, V], error)

Aug 1, 2026

Changes in this version

+ type Accept func(prev, next V) bool

+ type Hub struct

+ func New[K comparable, V any](opts ...Option[V]) *Hub[K, V]

+ func (h *Hub[K, V]) Close()

+ func (h *Hub[K, V]) Sender() *Sender[K, V]

+ func (h *Hub[K, V]) Watch(k K, initial V) *Receiver[K, V]

+ type Option func(*config[V])

+ func WithAccept[V any](fn Accept[V]) Option[V]

+ type Receiver struct

+ func (rx *Receiver[K, V]) Chan() <-chan gobus.Event[K, V]

+ func (rx *Receiver[K, V]) Close()

+ func (rx *Receiver[K, V]) Recv() (gobus.Event[K, V], error)

+ func (rx *Receiver[K, V]) RecvContext(ctx context.Context) (gobus.Event[K, V], error)

+ func (rx *Receiver[K, V]) TryRecv() (gobus.Event[K, V], error)

+ type Sender struct

+ func (tx *Sender[K, V]) Close()

+ func (tx *Sender[K, V]) Send(k K, v V) error

+ func (tx *Sender[K, V]) SendContext(ctx context.Context, k K, v V) error

+ func (tx *Sender[K, V]) TrySend(k K, v V) error