Rx.Observable.fromCallback(func, [scheduler], [context], [selector])

将一个回调函数转换成observable工厂函数.

参数

1. func (Function): 需要转换为Observable 的回调函数
2. [scheduler=Rx.Scheduler.timeout] (Scheduler): 执行回调函数的调度器。如果没有指定，则默认为Rx.Scheduler.timeout.
3. [context] (Any): 第一个函数参数的执行上下文。如果没有指定，则默认为 undefined
4. [selector] (Function): 它以第一个参数函数中返回的值作为本函数的参数，处理以产生下一个项。

返回值

(Function): 返回一个函数

例

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

// Wrap fs.exists
var exists = Rx.Observable.fromCallback(fs.exists);

// Check if file.txt exists
var source = exists('file.txt');

var subscription = source.subscribe(
    function (x) {
        console.log('Next: ' + result);
    },
    function (err) {
        console.log('Error: ' + err);   
    },
    function () {
        console.log('Completed');   
    });

// => Next: true
// => Completed