From

待定

待定

在單獨的 RxJavaAsyncUtil 套件中（預設情況下不包含在 RxGroovy 中），還有一個 runAsync 函數。將 runAsync 傳遞一個 Action 和一個 Scheduler，它將傳回一個 StoppableObservable，該 StoppableObservable 使用指定的 Action 來產生它發出的項目。

Action 接受一個 Observer 和一個 Subscription。它使用 Subscription 來檢查 isUnsubscribed 條件，如果滿足該條件，它將停止發出項目。您也可以隨時透過呼叫其 unsubscribe 方法來手動停止 StoppableObservable（這也會取消訂閱與 StoppableObservable 相關聯的 Subscription）。

由於 runAsync 會立即調用 Action 並開始發出項目，因此在您透過此方法建立 StoppableObservable 和 Observer 準備好接收項目之間的時間間隔中，可能會遺失一些項目。如果這是個問題，您可以使用 runAsync 的變體，該變體也接受一個 Subject，並傳遞一個 ReplaySubject，您可以使用它來擷取其他遺失的項目。

在單獨的 RxJavaAsyncUtil 套件中（預設情況下不包含在 RxJava 中），還有一個 runAsync 函數。將 runAsync 傳遞一個 Action 和一個 Scheduler，它將傳回一個 StoppableObservable，該 StoppableObservable 使用指定的 Action 來產生它發出的項目。

Action 接受一個 Observer 和一個 Subscription。它使用 Subscription 來檢查 isUnsubscribed 條件，如果滿足該條件，它將停止發出項目。您也可以隨時透過呼叫其 unsubscribe 方法來手動停止 StoppableObservable（這也會取消訂閱與 StoppableObservable 相關聯的 Subscription）。

由於 runAsync 會立即調用 Action 並開始發出項目，因此在您透過此方法建立 StoppableObservable 和 Observer 準備好接收項目之間的時間間隔中，可能會遺失一些項目。如果這是個問題，您可以使用 runAsync 的變體，該變體也接受一個 Subject，並傳遞一個 ReplaySubject，您可以使用它來擷取其他遺失的項目。

待定

RxJS 中有幾個特殊的 From 變體

還有一個 fromPromise 操作符，它將 Promise 轉換為 Observable，將其 resolve 呼叫轉換為 onNext 通知，並將其 reject 呼叫轉換為 onError 通知。

在以下發行版中可以找到 fromPromise

• rx.async.js (需要 rx.binding.js 以及 rx.js 或 rx.compat.js)
• rx.async.compat.js (需要 rx.binding.js 以及 rx.js 或 rx.compat.js)
• rx.lite.js
• rx.lite.compat.js

範例程式碼

var promise = new RSVP.Promise(function (resolve, reject) {
   resolve(42);
});

var source = Rx.Observable.fromPromise(promise);

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

Next: 42:
Completed

var promise = new RSVP.Promise(function (resolve, reject) {
   reject(new Error('reason'));
});

var source = Rx.Observable.fromPromise(promise);

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

Error: Error: reject

還有一個 ofArrayChanges 操作符，它使用 Array.observe 方法監視陣列，並傳回一個 Observable，該 Observable 發出陣列中發生的任何變更。此操作符僅在 rx.all.js 發行版中找到。

範例程式碼

var arr = [1,2,3];
var source = Rx.Observable.ofArrayChanges(arr);

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

arr.push(4)

Next: {type: "splice", object: Array[4], index: 3, removed: Array[0], addedCount: 1}

類似的操作符是 ofObjectChanges。它傳回一個 Observable，該 Observable 發出對特定物件所做的任何變更，如其 Object.observe 方法所報告。它也僅在 rx.all.js 發行版中找到。

範例程式碼

var obj = {x: 1};
var source = Rx.Observable.ofObjectChanges(obj);

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

obj.x = 42;

Next: {type: "update", object: Object, name: "x", oldValue: 1}

還有一個 pairs 操作符。此操作符接受一個物件，並傳回一個 Observable，該 Observable 以鍵/值對的形式發出該物件的屬性。

範例程式碼

var obj = {
  foo: 42,
  bar: 56,
  baz: 78
};

var source = Rx.Observable.pairs(obj);

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

Next: ['foo', 42]
Next: ['bar', 56]
Next: ['baz', 78]
Completed

在以下發行版中可以找到 pairs

• rx.js
• rx.all.js
• rx.all.compat.js
• rx.compat.js
• rx.lite.js
• rx.lite.compat.js

待定

待定

待定

待定

待定

在 Swift 中，這是使用 Observable.from 類別方法實作的。

陣列中的每個元素都會作為一個發射值產生。此方法與 Observable.just 的不同之處在於，後者將整個陣列作為一個發射值發出。

範例程式碼

let numbers = [1,2,3,4,5]

let source = Observable.from(numbers)

source.subscribe {
    print($0)
}

next(1)
next(2)
next(3)
next(4)
next(5)
completed