android - RxJava中如何根據(jù)已有的函數(shù)或函數(shù)回調(diào)創(chuàng)建Observable?
問題描述
在使用Rxjava過程中,可能已經(jīng)有很多函數(shù)回調(diào),那么怎么根據(jù)這些函數(shù)回調(diào)的參數(shù)創(chuàng)建數(shù)據(jù)流?比如如果我需要改造onKeyDown(),那么怎么根據(jù)傳來按鍵的不同,處理特定用戶輸入的序列,比如用戶輸入“1,2,3,4”的時(shí)候做特殊處理。
或者有其他的函數(shù)回調(diào),怎么將這些函數(shù)回調(diào)的數(shù)據(jù)使用bufferDebouncezip等操作符處理數(shù)據(jù)?
問題解答
回答1:可以這樣寫
private BehaviorSubject<Integer> bs; private void testSeri() {bs = BehaviorSubject.create();//每3次 accept 一次bs.buffer(3).subscribe(new Consumer<List<Integer>>() { @Override public void accept(@NonNull List<Integer> ints) throws Exception {StringBuilder sb = new StringBuilder();for (int i = 0; i < ints.size(); i++){ sb.append(ints.get(0));}Toast.makeText(TestSubjectActivity.this, sb.toString(), Toast.LENGTH_SHORT).show(); }}); } @Override public boolean onKeyDown(int keyCode, KeyEvent event) {bs.onNext(keyCode);return super.onKeyDown(keyCode, event); }
onKeyDown是Activity的回調(diào),不方便再包裝一層,因此用了Subject這種可以【隨時(shí)隨地】發(fā)射數(shù)據(jù)、訂閱和發(fā)射方便分開寫的發(fā)射器。對于一般的回調(diào)可以這樣寫,給你個(gè)百度定位的回調(diào)感受一下
class LocationObservable implements ObservableOnSubscribe<BDLocation> {@Overridepublic void subscribe(final ObservableEmitter<BDLocation> e) throws Exception { initLocation(); mLocationClient.registerLocationListener( new BDLocationListener(){@Overridepublic void onReceiveLocation(BDLocation location) { if (location != null) {mLocationClient.stop();if (!TextUtils.isEmpty(location.getCity())) { e.onNext(location); e.onComplete();} } else {// 定位失敗e.onError(new Exception('百度地圖 定位失敗')); }} } ); mLocationClient.start();} }
對于一般的函數(shù),可以這樣
Observable<String> o1 = Observable.fromCallable(new Callable<String>() { @Override public String call() {return func1(); }});public String func1(){ return 'ok';}
相關(guān)文章:
1. mysql - 如何減少使用或者不用LEFT JOIN查詢?2. 視頻文件不能播放,怎么辦?3. Python爬蟲如何爬取span和span中間的內(nèi)容并分別存入字典里?4. python - 編碼問題求助5. python - Scrapy存在內(nèi)存泄漏的問題。6. python - 我在使用pip install -r requirements.txt下載時(shí),為什么部分能下載,部分不能下載7. 網(wǎng)頁爬蟲 - python 爬取網(wǎng)站 并解析非json內(nèi)容8. mysql - 分庫分表、分區(qū)、讀寫分離 這些都是用在什么場景下 ,會帶來哪些效率或者其他方面的好處9. node.js - nodejs開發(fā)中常用的連接mysql的庫10. mysql - jdbc的問題
