_ __ ___ __  __ ___   ___
| '_ ` _ \  \/ /` _  \/ _  \
| | | | | |   /| (_| | (_| |
|_| |_| |_|__|  \___/ \___/

Make your own observables

This is my attempt to implement the ECMAScript Observable proposal

It is heavily inspired by the Ben Lesh's artice and RxJS.

One big difference to the RxJS is that RxJS uses the lift operator to create an observable and has far less (none?) closures.

Why?

Well I just want the truly understand Observables and thought the good way would be to implement them. This is very simple implementation and by far not complete. For the production you would probably want to use RxJS

Installation

ES6 via npm

npm install myoo

To import everything:

import * as Myoo from 'myoo/Myoo';

Myoo.Observable.of(1,2,3)

To import only what you need (Observable will be patched):

import {Observable} from 'myoo/Observable';
import 'myoo/add/operator/map';

Observable.of(1,2,3).map(x => x + '!!!'); // etc

To import what you need and use it with ES next function bind:

import {Observable} from 'myoo/Observable';
import {map} from 'myoo/operator/map';

Observable.of(1,2,3)::map(x => x + '!!!'); // etc

CommonJS via npm

npm install myoo

To import everything:

var Myoo = require('myoo/Myoo');

Myoo.Observable.of(1,2,3)

To import only what you need (Observable will be patched):

let Observable = require('myoo/Observable').Observable;
require('myoo/add/operator/map');

Observable.of(1,2,3).map(x => x + '!!!'); // etc

To import an operator and use it manually, do following:

var Observable = require('myoo/Observable').Observable;
var map = require('myoo/operator/map').map;

map.call(Observable.of(1,2,3), function (x) { return x + '!!!'; });

CDN

For CDN, you can use npmcdn:

https://npmcdn.com/[email protected]/bundles/Myoo.js

API

TODO

To be implemented

• Observable.prototype [@@observable]()
• Observable.from(x)
• More operators (and tests)
• Also use lift Operator concept to get rid of all those closures
• Add hot observables (maybe based on another Ben Lesh's article

License

MIT