A 4kb high performance alternative to RxJS.
If you are new to reactive programming then you should definitely checkout — The introduction to Reactive Programming you've been missing
const O = require('observable-air')
ES6 or Typescript
import * as O from 'observable-air'
<script src="https://unpkg.com/observable-air/.dist/observable-air.umd.min.js"></script> <script> O.forEach( console.log, O.scan((a) => a + 1, 0, O.interval(1000)) ) </script>
import * as O from 'observable-air' import * as R from 'ramda' const timer = R.compose( O.forEach(console.log), O.scan(R.add, 0), O.interval ) timer(100) // outputs 1, 2 ,3, 4 ... every 100ms timer(1000) // outputs 1, 2 ,3, 4 ... every 1000ms
npm install observable-air --save
Why an RxJS Alternative?
RxJS is awesome and an inspiration for this a lot of other observable libraries out there. Air is focussed on some fundamental things such as —
Smaller Footprint: Rx has a lot of operators which makes the library quite large in size. Air has a much smaller number of operators and is architected such that more sophisticated operators can be created using the already available ones without any performance overhead of composition.
Functional Over Fluidic: Air embraces a functional API rather than a fludic one. All the functions come curried out of the box and work really well with ramda.
Performance: Air is significantly faster than Rx, benchmarks coming up soon.
Virtual Time: In Rx
VirtualTimeScheduleris passed as an argument to each operator, in Air the
TestScheduleris passed once at the time of subscription and is internally shared up the chain of its parent operators or sources.