-
1 votesanswersviews
RxJava2问题:Zip并行处理多个服务时如何处理错误?
假设我们有3个服务,employeeTitle,employeeName,employeeLocation . 如果所有服务三个服务抛出employeeTitle错误,employeeName和employeeLocation只会抛出1个错误?根据文档,这应该是行为是正确的吗?如果只有employeeTitle抛出错误而其他服务成功,会发生什么?根据我的理解,如果employeeTitle抛出异常... -
2 votesanswersviews
如何使用RxJava2创建2个或2个并行网络请求?
我用Retrofit 2.0创建了两个不同的API请求 Observable<T> getOrganisationList() Observable<T> getStaffList() 我正在使用包含多个其他一次性用品的 CompositeDisposable 容器 . 我希望上述两个可观察请求并行执行 . Please, answer the question with... -
0 votesanswersviews
Retrofit2 RxJava2全局处理错误
如何使用retrofit2和rxjava2检查网络连接并且服务器是否可用于所有请求? 我可以通过向我的服务器URL发送请求来检查“服务器可用”,但是我可以通过向google.com或其他“好”网站发送请求来检查网络连接吗? 我有更多api请求,例如其中一个: compositeDisposable.add(RetrofitClient .getApi() ... -
1 votesanswersviews
RxAndroid运算符重试何时被调用但不重新订阅
使用Retrofit的API类 class interface TestApi { @GET("/path/abc/xyz") fun get(): Single } UseCase类 fun getResult(): Single { return testApi.get() .map{ response -> ... -
-2 votesanswersviews
Rxjava:我不打印
我不知道为什么这个程序不打印 . 我想要1秒钟打印字符串对象 . 所以我使用间隔 . 这个程序通常编译 . 但结果不打印 . 为什么?救命 . (我是韩国人 . 所以英语不成熟 . 对不起) public class main { public static void main(String[] args){ String str1 = "Apple&q... -
0 votesanswersviews
使用Observable.flatMap时的错误处理
下面有一个示例程序可以复制我的问题 . 问题: 将 flatMap 转换应用于某些 Observable 订阅前面提到的 Observable ,将订阅存储在某个地方 在 Observable 自然终止之前处置上述订阅 在映射器函数返回的 Observable 中,引发 Exception Flatmap运算符不知道如何处理 Exception ,引发它,程序崩溃/退出 首... -
2 votesanswersviews
Rxjava Realm从错误的线程访问
我正在从Realm读取/写入这个异常 06-19 09:49:26.352 11404-11404 / ****** E / ContentValues:loadData:OnError Realm从错误的线程访问 . Realm对象只能在创建它们的线程上访问 . java.lang.IllegalStateException:从错误的线程访问Realm . Realm对象只能在创建它们的... -
1 votesanswersviews
房间查询返回Maybe <List>在返回空结果时崩溃应用程序
我有房间查询: @Query("SELECT * FROM classes WHERE _id IN(:values) ORDER BY date DESC") fun getClassesByIds(values: List<Int>): Maybe<List<YClass>> compositeDisposable.add(viewM... -
1 votesanswersviews
使用Kotlin的RxJava和Retrofit
如何在 Kotlin 中使用 RxJava and Retrofit 为api调用创建泛型类? 我的JAVA实现如下:: 首先添加Gradle Dependency :(如果可用,更新到最新版本) //用于改造 实现'com.squareup.retrofit2:retrofit:2.3.0'implementation'com.squareup.retrofit2:converter-gson... -
0 votesanswersviews
使用Retrofit2和RxJava2组合请求
我正在尝试使用相同的 Observer 观察两个请求 . 我的 Observer : private BaseObserver<LoginResponse> loginObserver = new BaseObserver<LoginResponse>(this) { @Override public void onSubscribe(Disposable ... -
-1 votesanswersviews
如何使用RxJava2创建2或2个连续网络请求?
我用Retrofit 2.0创建了两个不同的API请求 Observable<T> getOrganisationList() Observable<T> getStaffList() 我正在使用 CompositeDisposable 容器,可以容纳多个其他一次性用品 . 我希望上述两个可观察的请求仅按顺序执行( getStaffList() 之后的 getStaffL... -
3 votesanswersviews
如何在RxJava2中并行执行使用者?
我有一个关于RxJava2的问题 . 我想在固定线程池的不同线程中运行使用者以并行执行List结果 . 这是我的代码: List<String> letters = Lists.newArrayList("a","b","c","d","e","f","g&... -
0 votesanswersviews
如何使用RxJava2和Retrofit2进行并行多个非阻塞服务请求
我需要一些帮助来实现使用RxJava2和Retrofit2的并行异步调用 . 我的要求是; 1)我有多个保险公司(现在我只拿两个),我需要使用该保险公司名称发送多个并行请求 . 2)如果其中任何一个给出服务器错误,那么剩余的请求不应该被阻止 . 以下是我到现在为止所做的事情; ArrayList<String> arrInsurer = new ArrayList<>();... -
4 votesanswersviews
从数据库网络加载数据(Room Retrofit RxJava2)
我有一个示例API请求,它返回用户监视列表的列表 . 我想实现以下 flow when the user loads the watchlist screen : 立即从数据库缓存加载数据 . ( cacheWatchList ) 在后台启动RetroFit网络呼叫 . 一世 . onSuccess 返回 apiWatchListII . onError 返回 cacheWat... -
1 votesanswersviews
将响应返回为Flowable时,不会调用onComplete
我正在尝试使用retrofit和rxjava 2进行webservie调用 . 我正在探索两种不同的方法来使用RxJava2 . 问题是我得到回应,我使用 Observable 但它不适用于 Flowable . 使用 Flowable 时我没有打印日志我尝试调试它但它不会进入 onNext 或 onComplete 或 onError . 只有 onSubscribe 被执行 . 1)使用o... -
0 votesanswersviews
Android RxJava Observable阻止ui
我正在使用rxJava并对我的请求进行改造,但是当我发出请求时,我的应用程序会冻结,直到请求完成 . 这是我在片段中启动请求的方式 MappingService.postSearch() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThr... -
0 votesanswersviews
RxJava没有在后台线程上运行
我正在尝试在Room中保存数据,它需要一些后台线程来保存数据 . 所以我创造了一个像这样的观察者 val obs: Observable<MutableLiveData<List<Source>>>? = Observable.fromCallable(object :Callable<MutableLiveData<List<Source&g... -
4 votesanswersviews
Retrofit2 RxJava2 RxAndroid错误
当我尝试创建 Subscriber 并订阅时,我收到如下错误消息 . can not resolve method 'subscribe(anonymous rx.Subscriber<GooglePlacesResponse>)' build.gradle // JSON Parsing compile 'com.google.code.gson:gson:2.6.1' compi... -
0 votesanswersviews
使用Retrofit2和rxJava2处理没有正文的响应
我有一个WS,如果成功则返回200没有正文,或者错误正文中的json为420则不成功 返回类型是 Observable<Response<Void>> 出于某种原因,如果出现420错误的错误,则调用 onNext(Response<Void> value) 而不是 onError(Throwable e) ,这是为任何其他不成功的请求调用的 . 为什么只在这种... -
0 votesanswersviews
Android RxJava2处理方向已更改
我是这个图书馆的新手,所以如果你有任何提示或建议,我们非常欢迎 . 我让RxJava2运行并执行longNetworkOperation假方法,流程如下: 创建observable:Observable.just("str1") 更改执行线程:.subscribeOn(Schedulers.newThread()) 实现将执行LongRunningProcess的m... -
0 votesanswersviews
使用rxjava2和retrofit2的多个请求
我正在使用retrofit2和rxjava2按顺序进行多个api调用 . 我发出请求以获取列表元素 . 之后,我需要为每个对象制作一个请求序列(不是并行) . 解决了递归功能 -
4 votesanswersviews
Rxjava observeOn和subscribeOn在Retrofit中
observeOn :此方法只是更改下游所有运营商的线程(https://medium.com/upday-devs/rxjava-subscribeon-vs-observeon-9af518ded53a) 在调用API时,我想在IO线程上运行与服务器的通信,并希望在mainThread上处理结果 . 我在许多教程中看到了下面的代码,毫无疑问它是正确的 . 但我的理解是相反的,所以我想知道我误解... -
1 votesanswersviews
retrofit2 rxjava2处理全局网络异常和自动身份验证
我有下一个处理错误的代码 . 此代码非常适合处理错误,但我想处理“未授权”错误 . public class RxErrorHandlingCallAdapterFactory extends CallAdapter.Factory { private RxJava2CallAdapterFactory rxJavaCallAdapterFactory; private Cont... -
0 votesanswersviews
Android retrofit2使用rxjava2
这是我的onCreate方法: - protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_dept); mAPIService = ApiUtils.getAPI... -
0 votesanswersviews
我可以有条件地“合并”一个单一的Observable吗?
我是一个RxJava新人,我在如何做以下事情时遇到了一些麻烦 . 我正在使用Retrofit来调用一个网络请求,该请求返回 Single<Foo> ,这是我最终想要通过我的Subscriber实例消费的类型(称之为 SingleFooSubscriber ) Foo 有一个内部属性 items ,类型为 List<String> . 如果 Foo.items ... -
0 votesanswersviews
SocketTimeoutException由RxJava未处理
我有一个使用sdk版本25开发的Android项目 . 我使用RXJava作为我的线程管理和Retrofit库来打网络 . 我还实现了自定义拦截器来添加覆盖有趣的拦截(链:Interceptor.Chain):响应? { val request = addHeader(chain) val response = chain.proceed(request) checkErrorR... -
0 votesanswersviews
RxJava2:并行调用多个服务时Zip如何处理错误?
假设我们有3个服务, employeeTitle , employeeName , employeeLocation . 如果所有服务三个服务抛出错误 employeeTitle , employeeName 和 employeeLocation 服务只会抛出1个错误?根据文档,这应该是行为是正确的吗?如果只有 employeeTitle 抛出错误而其他服务成功会发生什么?根据我的理解,如果 e... -
0 votesanswersviews
io.reactivex.exceptions.UndeliverableException:java.lang.StackOverflowError
我在我的应用程序中使用改造 . 我得到以下错误 . 我的Android移动操作系统是KitKat.Please帮我摆脱这个问题 . *W/System.err: io.reactivex.exceptions.UndeliverableException: java.lang.StackOverflowError at io.reactivex.plugins.RxJavaPlug... -
-2 votesanswersviews
Rxjava与kotlin
我在kotlin中使用rxjava 2,但它没有编译我应该如何解决它? var emailField = name.textChanges().skipInitialValue().toFlowable(BackpressureStrategy.LATEST) var passField = password.textChanges().skipInitialValue().toFlowable(... -
4 votesanswersviews
RxJava:observeOn,subscribeOn和doFinally,在IO和UI线程之间切换
我遇到了一个问题,我的observable在IO线程上订阅并在android主(UI)线程上观察但是 doFinally 运算符在IO线程上运行,它需要在UI线程上运行 . 用例与medium article几乎完全相同 . 我基本上想要在Observable订阅时显示 ProgressBar 并在Observable终止或结束时隐藏 ProgressBar . 我得到的错误是: java.la...