Versions in this module Expand all Collapse all v1 v1.0.1 Mar 23, 2021 v1.0.0 Mar 11, 2019 Changes in this version + var DefaultObservable = make(Observable) + func CheckEventHandler(handler rx.EventHandler) observer.Observer + type Observable <-chan interface + func (o Observable) Distinct(apply fx.KeySelectorFunc) Observable + func (o Observable) DistinctUntilChanged(apply fx.KeySelectorFunc) Observable + func (o Observable) Filter(apply fx.FilterableFunc) Observable + func (o Observable) First() Observable + func (o Observable) FlatMap(apply func(interface{}) Observable, maxInParallel uint) Observable + func (o Observable) Last() Observable + func (o Observable) Map(apply fx.MappableFunc) Observable + func (o Observable) Next() (interface{}, error) + func (o Observable) Scan(apply fx.ScannableFunc) Observable + func (o Observable) Skip(nth uint) Observable + func (o Observable) SkipLast(nth uint) Observable + func (o Observable) Subscribe(handler rx.EventHandler, opts ...Option) <-chan subscription.Subscription + func (o Observable) Take(nth uint) Observable + func (o Observable) TakeLast(nth uint) Observable + func Create(source func(emitter *observer.Observer, disposed bool)) Observable + func Empty() Observable + func From(it rx.Iterator) Observable + func Interval(term chan struct{}, interval time.Duration) Observable + func Just(item interface{}, items ...interface{}) Observable + func New(buffer uint) Observable + func Range(start, end int) Observable + func Repeat(item interface{}, ntimes ...int) Observable + func Start(f fx.EmittableFunc, fs ...fx.EmittableFunc) Observable + type Option interface + func WithParallelism(parallelism int) Option