jjzjj

observer

全部标签

java - "No Instance of type variable R exist so that Observable conforms to Observable"更新到 RxJava2 时出错

我正在尝试使用retrofit和rxJava调用API。下面的代码似乎在使用RxJava1时运行良好,但是一旦我更新到RxJava2我就收到了这个错误:错误:NoInstanceoftypevariableRexistsothatObservableconformstoObservableAPIObservable>>getList(@Query("key")Stringkey);Api请求在这里完成,这是我在.map运算符中得到这个错误的地方Observablecache=providers.getList().map(newHttpRsltFunc>());结果类模型:privat

android - 基于 Observable 的 API 和取消订阅问题

我正在尝试使用Rx-Java创建一个用于在Android上进行位置跟踪的类。我仍然无法弄清楚的是如何正确处理我的Observable的生命周期。我想要的是一个Observable,它在第一次订阅发生时开始跟踪位置,并在最后一个订阅被丢弃时停止位置跟踪。到目前为止,我取得的成就是:publicclassLocationObservableimplementsGooglePlayServicesClient.ConnectionCallbacks,GooglePlayServicesClient.OnConnectionFailedListener,LocationListener{pri

android - 如何在 onActivityResult 方法收到 Intent 结果后设置 Observer 以更新抽屉导航

在我的应用程序中,我想在他登录后使用用户名的昵称和电子邮件更新抽屉导航。从我的MainActivity我正在使用startActivityForResult(intent,PICK_ACCOUNT_REQUEST);方法启动一个LoginActivity让用户注册或登录。LoginActivity返回Intentdata结果(他的NAME和EMAIL)返回给后MainActivity,方法onActivityResult()被调用,我尝试更新类的全局变量NAME和EMAIL新收到的数据,没有成功:每次注册或登录后,这两个字段从未显示在抽屉导航中。这是我的代码:在MainActivity

java - 如何从非 Activity 线程调用 Activity ?

我有一个ObserverDesignpattern它使用线程发送我自己的Events。有时调用的类是AndroidActivity,有时是常规类。线程中的代码不是Activity。我收到这个错误:Can'tcreatehandlerinsidethreadthathasnotcalledLooper.prepare()为了避免运行时错误,我必须在Thread中添加Looper.prepare()。我知道这篇文章:Can'tcreatehandlerinsidethreadthathasnotcalledLooper.prepare()它包含此类问题的最佳信息,但我仍然不知道如何通过mj

android - RxAndroid,在 onDestroy() Activity 中停止计时器/observable.interval

我在我的应用程序中使用RxAndroid来处理计时器任务。用Observable.interval()来做。一切正常,但我需要在Activity的onDestroy()中停止计时器。我真的不知道怎么做。谁能帮帮我?这是我正在使用的代码:Observable.interval(0,10,TimeUnit.SECONDS).flatMap(n->mObservableNewChat).doOnError(i->showNoInternetConnection()).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainTh

java - 如何有条件地处理 Observable 链中的错误?

我正在使用onErrorReturn如果observable遇到错误,发出特定项目而不是调用onError:Observableobservable=getObservableSource();observable.onErrorReturn(error->"AllGood!").subscribeOn(Schedulers.io()).observeOn(Schedulers.trampoline()).subscribe(item->onNextAction(),error->onErrorAction());这工作正常,但我想在onErrorReturn仅当满足某些条件时消耗错误

android - 如果只有一个 Observable 参数存在,如何使用 RxJava Observable.zip

H,抱歉,我是RxJava的新手,对如何使用rx.Observable有疑问。这是我的代码finalObservabledata1=getData(...);finalObservabledata2=getData(...);finalObservabledata3=getData(...);returnObservable.zip(data1,data2,data3,newFunc3(){@OverridepublicSomeDatacall(finalSomeDatad1,finalSomeDatad2,finalSomeDatad3){//dosomethingandreturn

java - RxJava - Observable 的 zip 列表如果抛出异常如何获得成功响应

我正在尝试在Android中使用rxjava2并行调用多个API。它按照要求工作,但在任何api抛出异常的情况下,它无法给出其他API的响应,因此有什么方法可以调用返回成功响应的其他API。privatefungetStoreCouponData(){valuserObservable=repo2.create(StoreCouponsApi::class.java!!).getCoupons.subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread())valeventsObservable=

android - Observable 返回类型必须参数化为 Observable<Foo> 或 Observable<?扩展 Foo>

我正在使用改造2.0.0-beta2并且调试构建工作正常,但我在使用Proguard发布构建时遇到以下错误。这是更新后的logcat错误。11-1718:23:22.75116274-16274/ph.reggis.FEDTD/AndroidRuntime:ShuttingdownVM11-1718:23:22.75216274-16274/ph.reggis.FEDTE/AndroidRuntime:FATALEXCEPTION:main11-1718:23:22.75216274-16274/ph.reggis.FEDTE/AndroidRuntime:Process:ph.reg

android - 结合 RxTextView Observable 和 Retrofit Observable

作为开始使用RxAndroid的示例,我正在尝试实现一个搜索框,当用户插入内容时触发rest调用。到目前为止,我有两个工作部分。第一个观察EditTextView...RxTextView.textChangeEvents(searchEditText).debounce(400,TimeUnit.MILLISECONDS).observeOn(AndroidSchedulers.mainThread()).subscribe(newObserver(){@OverridepublicvoidonCompleted(){Timber.d("onCompleted");}@Overrid