Observable Air

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

Links

• Usage
• Example
• Installation
• Why an RxJS Alternative?
• API
• Demo

Usage

CommonJS

const O = require('observable-air')

ES6 or Typescript

import * as O from 'observable-air'

HTML

<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>

Example

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

Installation

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 —

1. 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.

2. 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.

3. Performance: Air is significantly faster than Rx, benchmarks coming up soon.

4. Virtual Time: In Rx VirtualTimeScheduler is passed as an argument to each operator, in Air the TestScheduler is passed once at the time of subscription and is internally shared up the chain of its parent operators or sources.