contentRxJava最初の最初AndroidKotlinこの記事はRxJavaの深い内容ではなく、初めて触れる際にそもそも、言葉がよくわからない、意味不明な人の最初のステップを対象としています。自分が初めて勉強した時に、ひたすら調べてまとめた感じなのでこれを読んで雰囲気でも感じとってもらえれば幸いです。完了していない状態、将来の設計図など言われる。Future同士をつなぎ合わせてパイプライン化することができる。使い分けを行うことで、使う側のObserver(Subscriber)で考えることを減らせるこれは型である。Observable(基本形)SingleMaybeCompletableFlowableSingleemitterのonSuccessかonErrorを呼ぶと1回だけObserverのonSuccessかonErrorが呼ばれる。値を流すかエラーかのどちらかの場合RetrofitでAPIからGETしてくる時などMaybeonSuccessかonCompleteかonErrorのどれか1つが1回だけ呼ばれる。CompletableonCompleteかonErrorのどちらかが1回だけ呼ばれる。Flowable参考ここに詳しく書いています。https://qiita.com/takahirom/items/f3e576e91b219c7239e7Scheduler処理を実行するスレッドを指定する。Observableがデータを生産する処理が行われるスレッド処理した結果を購読者が受け取る(または加工する)スレッドObservableがデータを生産する処理(subscribe()で実行される)が行われるスレッドの指定つまりAPI通信をするスレッド.subscriveOn(Schedulers.io())Observableが吐き出したデータを受け取って加工する場所を指定するスレッド結果の通知(UIスレッドで行う)、呼び出した以降のストリームを別のスレッドで実行Viewの更新をMainThreadでしか呼べないので非同期のリクエストなどを叩いた際はsubscribe()の直前で必ず呼び出す必要あり。非同期なブロッキングI/Oに向いたスケジューラ。内部的にはスレッドプールが作られワーカを再利用する。ネットワーク通信等に使われることが多いが、必要に応じてスレッドプールを大きくしていくのでOutOfMemoryErrorに注意する。CPUをガンガン使う計算に向いたスケジューラ。ブロックするI/O処理に向かない。同数)なので枯渇するとブロックする点に注意。タスクごとに新しいスレッドを立ち上げるスケジューラ。従ってioスケジューラ同様無制限にタスクが増えすぎてパフォーマンスの低下やOOMに注意する。タスクをAndroidのメインスレッドで実行するスケジューラオペレータObservableを作ったり、加工したり変換したりするための命令//TからObservableを作る.just//TからUへ1対1に変換する.mapなど膨大にあるらしいよって省略subscribeこれまでに設計図、スレッド処理、加工などを行って最後に実行するものが必要となります。それがsubscrivbe()になります。このタイミングで処理が開始され、コーヅバックに結果が通知される.subscribe()終わり基本的なので実際に使って行く際にはまた別の記事等参考にしてみてください。inc.東京理科大学発ベンチャー。提携大学内にソフトウェア研究所を組織し、学生向けのTech教育を提供しています。upLoginユーザーは見つかりませんでした。