Làm cách nào để hiển thị spinner nếu RxJava có thể quan sát được lâu?

Question

Tôi cảm thấy như ai đó đã thử điều này, nhưng tôi không thể tìm ra một cách tốt đẹp để làm điều gì đó nếu có thể quan sát được lâu.

Đây là luồng tôi muốn.

Start a search. 
If the search takes longer than some time, 
    show a spinner or show progress bar. 
When finished do subscription action and hide spinner/progress bar. 

Gần nhất tôi có thể nghĩ là giống như một Zip

manager.search(searchTerm) 
     .zip(Observable.Timer(1, TimeUnit.SECONDS)) 
     .subscribe(
      // if the search is non null then we are good 
      // if the long time is non 0 we need to show spinner 
     ); 

Có điều gì tốt hơn để làm gì? Tôi đã cố gắng cả ngày và không thành công. Trong một thế giới hoàn hảo Tôi cảm thấy như tôi muốn một cái gì đó giống như

manager.search(searchTerm) 
     .timeout(i -> /* do timeout stuff */, 1, TimeUnit.SECONDS) 
     .subscribe(item -> /* do search result stuff */); 

Answer 1

Bạn có thể làm điều này bằng việc xuất bản tìm kiếm Quan sát qua thời gian chờ:

Observable<Integer> source = Observable.just(1).delay(5, TimeUnit.SECONDS); 

source 
.doOnSubscribe(() -> System.out.println("Starting")) 
.publish(o -> 
    o.timeout(1, TimeUnit.SECONDS, Observable.<Integer>fromCallable(() -> { 
     System.out.println("Spinning..."); 
     return null; 
    })).ignoreElements().mergeWith(o) 
) 
.toBlocking() 
.subscribe(v -> { 
    System.out.println("Hide spinner if shown."); 
    System.out.println(v); 
}); 

này hoạt động bằng cách phân chia các nguồn thành hai làn xe nóng: làn đầu tiên sẽ chạy một toán tử timeout mà khi hết thời gian, bắt đầu một Quan sát khác với tác dụng phụ cho biết điều khiển quay. Một trong những cách là sử dụng fromCallable cho điều này và bỏ qua kết quả của nó (điều này cũng tránh trùng lặp). Làn thứ hai sẽ không thay đổi và được hợp nhất với làn thời gian chờ để phân phối giá trị thực tế.