Modular Reactive Extensions for JavaScript RxJS
Reactive Extensions for JavaScript (RxJS) composed entirely of small modules.
The intent for this project is to make each operator available as its own export. For example, one could map and filter a given source such as the following:
var map = require('rx.observable.map');
var filter = require('rx.observable.filter');
var ofItems = require('rx.observable.of');
var source =
filter(
map(
ofItems(1,2,3,4,5),
function (x, i, o) {
return x * x + i;
}),
function (x, i, o) {
return x % 2 === 0;
}
);
source.subscribe(
function (x) {
console.log('Next', x);
});
// => Next 2
// => Next 10
// => Next 26
Alternatively, you can chain them together very easily such as the following.
var Observable = require('rx.observable');
var map = require('rx.observable.map');
var filter = require('rx.observable.filter');
var ofItems = require('rx.observable.of');
Observable.prototype.map = function (selector, thisArg) {
return map(this, selector, thisArg);
};
Observable.prototype.filter = function (predicate, thisArg) {
return filter(this, predicate, thisArg);
};
Observable.of = function () {
ofItems.call(null, arguments);
};
var source = Observable.of(1,2,3,4,5)
.map(function (x, i, o) {
return x * x + i;
})
.filter(function (x, i, o) {
return x % 2 === 0;
});
source.subscribe(
function (x) {
console.log('Next', x);
});
// => Next 2
// => Next 10
// => Next 26
Implemented and Planned Modules
Note that this is a work in progress and feedback is welcome!
Collections
rx.priorityqueue
-PriorityQueue
Core
rx.observable
-Observable
rx.observer
-Observer
Core Operators
rx.observable.combinelatest
-combinelatest
rx.observable.create
-create
rx.observable.filter
-filter
rx.observable.from
-from
rx.observable.of
-of
rx.observable.map
-map
rx.observable.zip
-zip
Disposables
rx.compositedisposable
-CompositeDisposable
rx.disposable
-Disposable
rx.serialdisposable
-SerialDisposable
rx.singleassignmentdisposable
-SingleAssignmentDisposable
Schedulers
rx.scheduler
-Scheduler
rx.currentthreadscheduler
-CurrentThreadScheduler
rx.defaultscheduler
-DefaultScheduler
rx.immediatescheduler
-ImmediateScheduler
rx.testscheduler
-TestScheduler
rx.virtualtimescheduler
-VirtualTimeScheduler
Utilities
rx.utils
-utils
License
Copyright (c) Microsoft All rights reserved.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.