ObservableまたはFlowableに複数のサブスクライバをサブスクライブするには？ Hello Worldの例では

Question

1人の加入者2以上にする方法

public static void main(String[] args) { 
     Flowable.just("Hello world").subscribe(System.out::println); 
    } 

がありますか？

Answer 1

観測可能な/流動可能なものに複数のサブタブをサブスクライブすることができます。 subscribeコールを必要なだけ何度も繰り返してください。

Flowable<String> source = Flowable.just("Hello world"); 
source.subscribe(System.out::println); 
source.subscribe(System.out::println); 
... 

彼らは、このような複数のサブスクリプションを処理する方法でホットと冷たい観測の違いがあります。

コールド observables/flowablesは、新規加入者ごとにソースからアイテムを再リクエストします。たとえば、Flowable.fromCallable(c)は、購読するたびにcを呼び出します。

ホット observables/flowablesは、すべてのサブスクライバと同じソースサブスクリプションを共有します。つまり、新しいサブスクライバごとにソースから新しいアイテムを要求しません。新しいアイテムは、現在登録されているすべてのサブスクライバに伝播します。