Versions in this module Expand all Collapse all v1 v1.0.2 Apr 25, 2024 v1.0.1 Apr 24, 2024 Changes in this version + type Iterable <-chan T + type Observable struct + func NewObservable[T any](iter Iterable[T]) *Observable[T] + func (o *Observable[T]) Subscribe() (Subscription[T], error) + func (o *Observable[T]) UnSubscribe(sub Subscription[T]) + type Subscriber struct + func (s *Subscriber[T]) Close() + func (s *Subscriber[T]) Emit(item T) + func (s *Subscriber[T]) Out() Subscription[T] + type Subscription <-chan T
Go to main page