草庐IT

redux-observable

全部标签

使用Redux-Observable处理Apollo-Client的错误

我正在使用Apollo-Client和Redux-Observable进行突变,到目前为止,这是我的代码:exportconstlanguageTimeZoneEpic=(action$)=>{returnaction$.ofType('PING').flatMap(action=>client.mutate({mutation:languageTimeZoneIdMutation,variables:{id:action.id,defaultLanguage:action.selected_language,defaultTimeZoneId:action.selected_timeZone

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

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

android - 在 Android 中使用 Redux 结构和 Firebase

我最近刚开始使用Redux我想用它创建一个简单的应用程序。我已经用自己的State、Reducer和Action实现完成了主要结构。但我想知道如何使用Firebase将“数据”部分添加到应用程序中。我的意思是,这可能是按照Redux的应用程序状态模式构建和外部化数据调用的最佳实践。我已经考虑过创建一个Controller并分派(dispatch)调用数据的操作,但是Firebase使用大量回调,所以我没有找到一个好的方法来按照这种模式管理它们。在遵循Redux模式的Android应用程序中构建数据模型有哪些好的做法? 最佳答案 我一

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