andarist Goto Github PK

callbag-distinct-until-changed

👜 Callbag operator that drops consecutive duplicate values

callbag-drop-after

👜 Callbag operator that drops all events after the first event for which predicate returns true.

callbag-drop-until

Starts emitting the input stream when another stream emits a value.

callbag-duration-progress

👜 Callbag listenable source which emits value describing time progress (number between 0 an 1) since the subscription (using requestAnimationFrame) - useful for animations.

callbag-element-at

👜 Callbag operator that emits the single value at the specified index.

callbag-empty

👜 Callbag source that emits no data and completes immediately.

callbag-exhaust-map

👜 Callbag operator that maps to inner source and ignores other values until that source completes.

callbag-filter

👜 Callbag operator that conditionally lets data pass through

callbag-flatten

👜 Callbag operator that flattens a higher-order callbag source

callbag-flatten-iter

Callbag operator that flattens iterables

callbag-flatten-sequentially

callbag-for-each

👜 Callbag sink that consume both pullable and listenable sources

callbag-from-channel

callbag-from-delegated-event

callbag-from-event

👜 Create a Callbag listenable source from events on a DOM node

callbag-from-event-pattern

👜 Callbag source factory from addHandler and removeHandler pair.

callbag-from-function

callbag-from-iter

👜 Convert an iterable or iterator to a callbag pullable source

callbag-from-obs

👜 Convert an observable to a callbag listenable source

callbag-from-promise

👜 Convert a Promise to a callbag listenable source

callbag-interval

👜 A callbag listenable source that sends incremental numbers every x milliseconds.

callbag-last

Callbag operator that emit the last value emitted from source on completion, based on provided expression.

callbag-last-element

👜 Callbag operator that emits only the last item emitted by the source.

callbag-latest

callbag-lazy

Callbag source for lazy evaluation

callbag-loop

👜 Callbag operator that accumulates results using a feedback loop that emits one value and feeds back another to be used in the next iteration.

callbag-map

👜 Callbag operator that applies a transformation on data passing through it

callbag-map-to

callbag-map-when

Callbag operator that maps over values that satisfies a predicate. AKA filterMap

callbag-merge

👜 Callbag factory that merges data from multiple callbag sources