Reactive Extensions for JavaScript (RxJS) version 2.2.4

Minor update from v2.2.3 which shortcuts behavior for callbacks with only a single value.

The old behavior of Rx.Observable.fromCallback and Rx.Observable.fromNodeCallback was to by default return an array, even if only a single value.

var Rx = require('rx'),
    fs = require('fs');

var stat = Rx.Observable.fromNodeCallback(
    fs.stat,
    null, /* default scheduler */
    null, /* default context */,
    function (arr) { return arr[0]; }); /* only return the first */

var files = ['file1.txt', 'file2.txt', 'file3.txt'];

Rx.Observable
    .for(files, function (file) {
        return stat(file);
    })
    .toArray()
    .subscribe(
        function (results) {
            results.forEach(function (result) {
                console.log('is file: ' + result.isFile());
            });
        },
        function (err) {
            console.log('err ' + err);
        }
    );

The new behavior shortcuts this if there is only one parameter and returns it as a single value.

var Rx = require('rx'),
    fs = require('fs');

var stat = Rx.Observable.fromNodeCallback(fs.stat);

var files = ['file1.txt', 'file2.txt', 'file3.txt'];

Rx.Observable
    .for(files, function (file) {
        return stat(file);
    })
    .toArray()
    .subscribe(
        function (results) {
            results.forEach(function (result) {
                console.log('is file: ' + result.isFile());
            });
        },
        function (err) {
            console.log('err ' + err);
        }
    );