Versions in this module Expand all Collapse all v1 v1.19.0 Nov 25, 2023 Changes in this version + type Iterable <-chan any + 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 any) + func (s *Subscriber) Out() Subscription + type Subscription <-chan any