goob

Jan 4, 2026

Changes in this version

+ func NewPipe(ctx context.Context) (Write func(Event), Events <-chan Event)

+ type Event interface

+ type Events <-chan Event

+ type Observable struct

+ func New(ctx context.Context) *Observable

+ func (ob *Observable) Len() int

+ func (ob *Observable) Publish(e Event)

+ func (ob *Observable) Subscribe(ctx context.Context) Events