staltz/callbag-pipe

tap-producing test harness for node and browsers

Callbag operator that applies a transformation on data passing through it

Callbag operator that conditionally lets data pass through

Callbag sink that consume both pullable and listenable sources

Convert an iterable or iterator to a callbag pullable source

AST querying for lazy people

Chat UI Kit

apply streaming operators (like debounce) on your component state / props

Themed JSS styles

An SPA router using Callbags.

common callbags

keyed callbag states

Callbag-based State Management

Expressions with callbags

callbags + JSX: super fast and super thiny interactive web apps

👜 Callbag operator which emits values emitted by the source as long as each value satisfies the given predicate, and then completes as soon as predicate is not satisfied. But call lastly function before callbag is over.

👜 Callbag operator which accumulates source values until a separator emits

Basic tallbag factories and operators to get started with

provides objectel event helper

provides api to manipulate highly-abstracted object in order to resolve hierarchical problem via composition

provides objectel event helper

provides api to manipulate highly-abstracted object in order to resolve hierarchical problem via composition

Web Component Library based on callbag

👜 Callbag Pause let you pause/resume your callbag stream with a boolean var.

👜 Callbag operator which resubscribes to the source given amount of times.

👜 Convert React value (i.e. props or state) to a callbag source.

👜 Callbag operator that maps to inner source, subscribe and emit in order.

👜 Callbag operators for the best tests.

👜 Callbag operators for the best tests.

Refract bindings for Preact with Callbag: harness the power of reactive programming to supercharge your components!

Refract bindings for Inferno with Callbag: harness the power of reactive programming to supercharge your components!

👜 Callbag operator which emits values emitted by the source as long as each value satisfies the given predicate, and then completes as soon as predicate is not satisfied.