Observableify a callback-style function
$ npm install --save obsify
const fs = require('fs');
const obsify = require('obsify');
obsify(fs.readFile)('package.json', 'utf8')
.map(data => JSON.parse(data))
.subscribe(data => {
console.log(data.name);
//=> 'obsify'
});
// or observableify all methods in a module
obsify(fs).readFile('package.json', 'utf8')
.map(data => JSON.parse(data))
.subscribe(data => {
console.log(data.name);
//=> 'obsify'
});Type: function, object
Callback-style function or module whose methods you want to observableify.
Type: array of (string|regex)
Methods in a module to observableify. Remaining methods will be left untouched.
Type: array of (string|regex)
Default: [/.+Sync$/]
Methods in a module not to observableify. Methods with names ending with 'Sync' are excluded by default.
Type: boolean
Default: false
By default, if given module is a function itself, this function will be observableified. Turn this option on if you want to observableify only methods of the module.
const obsify = require('obsify');
function fn() {
return true;
}
fn.method = (data, callback) => {
setImmediate(() => {
callback(data, null);
});
};
// observableify methods but not fn()
const observableFn = obsify(fn, {excludeMain: true});
if (observableFn()) {
observableFn.method('hi').subscribe(data => {
console.log(data);
});
}MIT © Sam Verschueren