Flexible and debuggable lazy primitive.
Throttle operator for callbags, enforcing a cooldown quiet time between emissions (during which arrivals are dropped)
Callbag operator that returns data passing through it via a callback
Callbag operator that Drops consecutive duplicate
A callbag operator that flattens/merges sources
Tallbag operator that conditionally lets data pass through
A meta collection package for GeoloeG custom Polymer Elements.
Callbag operator that merges all items a source of sources into a single output source
A custom element that sets its contents from a callbag stream
Tallbag operator that applies a transformation on data passing through it
bucket manager
A callbag operator that maps items to sources and flattens them lazily
Callbag operator that maps over values that satisfies a predicate. AKA filterMap
Callbag operator for graceful error handling
Delays the emission of items from the source Callbag by a given timeout
Tallbag operator that combines consecutive values from the same source
Callbag factory that yields the Cartesian product (all combinations) of source callbags
Tallbag factory that combines data from multiple tallbag sources
Tallbag factory that merges data from multiple tallbag sources
Callbag operator that applies a transformation, which may be dot-notated path, on data passing through it
Tallbag factory that concatenates data from multiple tallbag sources
callbag that distributes (shared) sources to many sinks
Tallbag operator that limits the total amount of data sent through
A callbag operator that switches to latest listenable source result