如何訂閱Observable或Flowable的幾個訂戶？

Question

在Hello World示例有一個用戶

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

如何使兩個或更多？

Answer 1

你可以訂閱多個subsperses任何可觀察/流動。根據需要重複撥打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與所有用戶共享同一源訂閱，即它們不會從每個新訂戶的源請求新的項目。新項目會傳播給所有當前訂閱的訂閱者。