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);
}
);