Rxjava-creating-observables

RxJava-オブザーバブルの作成

以下は、オブザーバブルを作成するための基本クラスです。

• Flowable -0..Nフロー、0またはnアイテムを放出します。 リアクティブストリームとバックプレッシャーをサポートします。
• Observable -0..Nのフローですが、背圧はありません。
• Single -1アイテムまたはエラー。 メソッド呼び出しのリアクティブバージョンとして扱うことができます。
• 完了-アイテムは放出されません。 完了またはエラーのシグナルとして使用されます。 Runnableのリアクティブバージョンとして扱うことができます。
• MayBe -アイテムなし、または1アイテムが放出されました。 Optionalの事後対応バージョンとして扱うことができます。

以下は、Observableクラスでオブザーバブルを作成する便利なメソッドです。

• * just（T item）*-指定された（定数参照）アイテムを通知するObservableを返し、完了します。
• * fromIterable（Iterable source）*-Iterableシーケンスを、シーケンス内のアイテムを放出するObservableSourceに変換します。
• * fromArray（T …​ items）*-配列内のアイテムを出力するObservableSourceに配列を変換します。
• * fromCallable（Callable supplier）*-Observableを返します。オブザーバーがサブスクライブすると、指定した関数を呼び出し、その関数から返された値を発行します。
• * fromFuture（Future future）*-FutureをObservableSourceに変換します。
• * interval（long initialDelay、long period、TimeUnit unit）*-initialDelayの後に0Lを出力し、その後の各期間の後に数値を増加させるObservableを返します。