callbag
There are 91 repositories under callbag topic.
Andarist/callbag-remember
👜 Callbag operator that remembers last event, so that a newly added listener will immediately receive that memorised event.
Andarist/callbag-sample-when
👜 Callbag operator that samples from source when provided listenable emits.
willisplummer/callbag-trace
Callbag operator that logs values to the console midstream for simpler debugging
Andarist/callbag-buffer
👜 Callbag operator which buffers source values until separator stream emits.
Andarist/callbag-buffer-time
👜 Callbag operator which buffers source values until provided time has passed.
Andarist/callbag-concat-map
👜 Callbag operator that maps to inner source, subscribe and emit in order.
Andarist/callbag-defer
👜 Callbag which creates a source from a given factory when sink subscribes.
Andarist/callbag-drop-until
Starts emitting the input stream when another stream emits a value.
Andarist/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.
Andarist/callbag-element-at
👜 Callbag operator that emits the single value at the specified index.
Andarist/callbag-last-element
👜 Callbag operator that emits only the last item emitted by the source.
Andarist/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.
Andarist/callbag-never
👜 Callbag source that never completes and emits no data.
Andarist/callbag-time-interval
👜 Callbag operator which emits the value with time elapsed since last emission.
Andarist/callbag-timeout
👜 Callbag operator which errors if source does not emit before specified duration.
Andarist/callbag-timer
👜 Callbag source that after given duration emits numbers in sequence every specified duration.
ds82/callbag-replay-all
👜 callbag-replay-all - Remembers all emited values and replays them to every new sink
leslieJt/callbag-last
Callbag operator that emit the last value emitted from source on completion, based on provided expression.
lund0n/callbag-buffer-until
👜 Callbag operator that buffers the stream until another stream emits a value.
sartaj/callbag-from-events
👜Create a Callbag from any object with on/off methods, a DOM EventTarget, or a Node.JS EventEmitter.
swift-callbag/callbag-kit
🧰 fast reactive/iterable programming framework
totorototo/template
react template project. state and state management: refract, callbag, redux. design system: styled-system
Andarist/callbag-concat-with
👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.
Andarist/callbag-distinct-until-changed
👜 Callbag operator that drops consecutive duplicate values
Andarist/callbag-drop-after
👜 Callbag operator that drops all events after the first event for which predicate returns true.
Andarist/callbag-empty
👜 Callbag source that emits no data and completes immediately.
Andarist/callbag-from-event-pattern
👜 Callbag source factory from addHandler and removeHandler pair.
Andarist/callbag-pairwise
👜 Callbag operator that groups pairs of consecutive emissions together and emits them as an array of two values.
Andarist/callbag-partition
👜 Callbag operator that splits the source into two, based on predicate function.
Andarist/callbag-pluck
👜 Callbag operator that maps to object properties.
Andarist/callbag-tap-up
👜 Callbag operator which performs a side effect for every upwards emission (from sink to source), but other than that it acts as noop.
Andarist/callbag-throw-error
👜 Callbag source factory that immediately emits an error.
leslieJt/callbag-first
Callbag operator that emit the first value emitted from source on completion, based on provided expression.
mr-rampage/java-callbags
:handbag: Java implementation of callbags