それぞれの出力が次の入力であるオブザーバブルの配列

Question

複数のデータソースに対してアクションを実行するためにRxSwiftを使用しようとしています。しかし、私はどのように次のことを達成するための考えがありません。

私は、それぞれの出力が次の入力でなければならないという観測の配列を持っています。だから、私は、最初のものを観測可能にし、結果を待って次のものに渡し、配列の終わりに至るまで最終的な値を返すような何かをしたい。

これは可能ですか？前もって感謝します。

***アップデート：要望に応じて、具体的に説明します。

私が配列で使用している 'observables'はカスタムです。私はObservable.create { ... }を返す関数を使用します。クロージャの内部では、値を変換した非同期操作を実行し、完了する前にオブザーバに結果を送信します。その結果の値は、次の観測値に渡されなければならず、最終的な値を得るためには、配列内の最後の観測可能値まで続きます。

観測値は複数の値を送信することがありますが、観測値は1つの観測値から次の観測値まで、組立ラインのように渡さなければなりません。

Answer 1

Observableは入力が正確ではないので、あなたが求めているものを正確に知ることは難しいですが、これはよくある問題だと思います。

Observableから放出された値からデータを集めることができるconcatまたはreduce演算子の組み合わせを検索している可能性があります。 ReactiveX's documentation for Mathematical and Aggregate Operatorsを参照してください。

// "I have an array of observables..." 
let one = Observable.deferred { Observable.just(1) } 
let two = Observable.deferred { Observable.just(2) } 
let observables = [one, two] 

// "the output of each, should be the input of the next" 
// this is problematic, because observables do not strictly have inputs. 
let resultsFromEach = Observable.concat(observables) 

resultsFromEach 
    .reduce(0) { result, next in 
     result + 1 
    } 
    .debug("result") 
    .subscribe()