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 + type Connectable struct + func Empty() Connectable + func From(it rx.Iterator) Connectable + func Interval(term chan struct{}, timeout time.Duration) Connectable + func Just(item interface{}, items ...interface{}) Connectable + func New(buffer uint, observers ...observer.Observer) Connectable + func Range(start, end int) Connectable + func Start(f fx.EmittableFunc, fs ...fx.EmittableFunc) Connectable + func (co Connectable) Connect() <-chan (chan subscription.Subscription) + func (co Connectable) Distinct(apply fx.KeySelectorFunc) Connectable + func (co Connectable) DistinctUntilChanged(apply fx.KeySelectorFunc) Connectable + func (co Connectable) Do(nextf func(interface{})) Connectable + func (co Connectable) Filter(fn fx.FilterableFunc) Connectable + func (co Connectable) First() Connectable + func (co Connectable) Last() Connectable + func (co Connectable) Map(fn fx.MappableFunc) Connectable + func (co Connectable) Scan(apply fx.ScannableFunc) Connectable + func (co Connectable) Subscribe(handler rx.EventHandler) Connectable