android - RxJavar用什么操作符可以使數據每隔一段時間取出一個
問題描述
RxJavar用什么操作符可以使數據每隔一段時間取出一個
問題解答
回答1:懶得去搞 Java 的環境,給你個 JavaScript 的示例,你照著改成 Java 的吧
const Rx = require('rx');Rx.Observable.range(0, 10) .map(n => 3 + n * 10) .concatMap((x, i) => {return Rx.Observable.interval(500) .take(1) .map(() => `${x}:${i}`); }) .do(console.log) .subscribe();
補充一下
interval(500).take(1) 可以用 timer(500) 代替
使用 concatMap() 或者 map().concat()
]
private Object getData(int index) { //TODO 獲取第n個數據}Observable.interval(1, TimeUnit.SECONDS)//每秒執行一次 .flatMap(i->Observable.fromCallable(()->getData(i.intValue())))//獲取數據 .subscribe(s->System.out.println(s));//獲取數據后的處理方法
如果獲取對象的方法是快速執行的方法,flatMap也可以使用map來代替,改成
.map(i->getData(i.intValue()))//獲取數據
相關文章:
1. mysql優化 - MySQL如何為配置表建立索引?2. 如何用筆記本上的apache做微信開發的服務器3. 我在網址中輸入localhost/abc.php顯示的是not found是為什么呢?4. 數據庫 - Mysql的存儲過程真的是個坑!求助下面的存儲過程哪里錯啦,實在是找不到哪里的問題了。5. 關于mysql聯合查詢一對多的顯示結果問題6. 冒昧問一下,我這php代碼哪里出錯了???7. windows誤人子弟啊8. php傳對應的id值為什么傳不了啊有木有大神會的看我下方截圖9. MySQL主鍵沖突時的更新操作和替換操作在功能上有什么差別(如圖)10. 實現bing搜索工具urlAPI提交
