Versions in this module Expand all Collapse all v0 v0.1.0 Sep 6, 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
Go to main page