Versions in this module Expand all Collapse all v1 v1.0.0 Nov 4, 2022 Changes in this version + type Iterable <-chan interface + type Observable struct + func NewObservable(any Iterable) *Observable + func (o *Observable) Subscribe() (Subscription, error) + func (o *Observable) UnSubscribe(sub Subscription) + type Subscriber struct + func (s *Subscriber) Close() + func (s *Subscriber) Emit(item interface{}) + func (s *Subscriber) Out() Subscription + type Subscription <-chan interface
Go to main page