goob

Apr 9, 2022

Changes in this version

+ type Events <-chan Event

Oct 14, 2020

Changes in this version

type Observable

+ func (ob *Observable) Close()

+ func (ob *Observable) Len() int

+ func (ob *Observable) Unsubscribe(s Subscriber)

type Pipe

+ Events <-chan Event

+ Stop func()

+ Write func(Event)

+ func NewPipe() *Pipe

+ type Subscriber <-chan Event

Oct 6, 2020

Changes in this version

+ func Pipe(ctx context.Context) (w func(Event), r <-chan Event)

Jun 11, 2020

Changes in this version

type Observable

+ func (ob *Observable) Count() int

Jun 8, 2020

Changes in this version

+ func Each(s chan Event, iteratee interface{})

+ type Event interface

+ type Observable struct

+ func New() *Observable

+ func (ob *Observable) Filter(ctx context.Context, iteratee interface{}) *Observable

+ func (ob *Observable) Map(ctx context.Context, iteratee interface{}) *Observable

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

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