rxjs - Observable.create 和 Observable.createWithDisposable 之间的区别

Question

Observable.create和 和有什么不一样Observable.createWithDisposable？我看不到文档或查看源代码的区别。

Answer 1

看起来像用返回默认一次性用品的 acreateWithDisposable包装用户提供的subscribe函数，而明确要求用户提供的函数返回一次性用品。subscribecreatesubscribe

Answer 2

[create] 是该createWithDisposable方法的别名。

https://github.com/Reactive-Extensions/RxJS/blob/d94905a34ba9953e705975acce136c0d0dbd495e/doc/api/core/operators/create.md

这两个功能可以互换。createWithDisposable已被弃用。你应该使用create.

createfunction 可以返回一个函数，该函数将在处理订阅时调用（此函数必须用于清理）。

var source,
    subscription;

source = Rx.Observable.create(function (observer) {
    // ..

    return function () {
        console.log('disposed');
    };
});

subscription = source.subscribe();

subscription.dispose();

<script src='https://rawgit.com/Reactive-Extensions/RxJS/v.2.5.3/dist/rx.all.js'></script>