mosaic-reactive

# mosaic-reactive

A very simple reactive framework inspired by the http://reactivex.io/.
Features:
* 350 lines of code; 8Kb (non minimized)
* Based on PromiseA-compliant promises; can be used with any external promise
implementations.
* Each stream is a deferred object with resolve/reject/then methods. Main methods:
- Deferred
- Stream
* Provides the following methods:
- buffered
- each
- filter
- index
- map
- merge
- pipe
- zip
* Experimental methods
- delay
- interval

Example:
``
// var Promise = require('promise'); // - not required in NodeJS environment
var reactive = require('mosaic-reactive');

var source = reactive.Stream(Promise, {
methods : reactive
});

var out = source.map(function(value) {
return value.toUpperCase();
}).each(function(value) {
console.log('* ', value);
});

var array = [ 'first', 'second', 'third', 'fourth', 'fifth' ];
array.forEach(source.emit);
source.end();

return out.then(function() {
console.log('Finished');
}, function(err) {
console.log('Error!', err);
});


``