【Kotlin/Android】RxJavaのconcatWithメソッドの使い方!直列処理の実装

この記事からわかること
- Android Studio/KotlinでRxJavaの使い方
Observable
のconcatWithメソッドの使い方- 非同期処理を順番に実行するには?
\ アプリをリリースしました /
環境
- Android Studio:Flamingo
- Kotlin:1.8.20
Operator:concatWithメソッドの使い方
RxJavaのObservable
で使用できるOperatorのconcatWith
は非同期処理を順番に処理するためのメソッドです。「非同期処理Aの完了後に非同期処理Bを実行したい」場合などObservable
を直列に繋げたい場合に使用します。Completable
の場合はandThen
メソッドが同じ役割になります。
完了後に実行したい非同期処理をconcatWith
メソッドの引数に渡します。
例えば上記の場合は「処理開始」が出力されobservable1が全て出力された後にobservable2が実行されることになります。concatWith
メソッドにObservable
を渡した場合はさらにメソッドチェーンで複数のObservable
を掛け合わせて実装することも可能です。
- 処理開始
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
異なる非同期処理を渡す
concatWith
メソッドの引数に渡す非同期処理はObservable
以外でも問題ありません。
concatメソッドの使い方と違い
concat
もconcatWith
同様に非同期処理を順番に処理するためのメソッドです。違うのは以下の点になります。
concatWithメソッド
- インスタンスメソッド
- 引数には完了後に行いたいObservableを1つ渡す
concatメソッド
- 静的メソッド
- 引数には完了後に行いたいObservableを複数渡す
そのため複数のObservableを直列に繋げるときはconcat
メソッドを使用することでスッキリ記述することが可能です。
まだまだ勉強中ですので間違っている点や至らぬ点がありましたら教えていただけると助かります。
ご覧いただきありがとうございました。