-
1 votesanswersviews
RxJava Observable
我正在努力研究我的第一个RxJava示例 我有一个带有文本框和三个按钮的主要活动 . 第一个按钮在单独的类中初始化一个整数 . 第二个按钮订阅了一个观察整数的观察者 . 第三个按钮将整数值减一 . 这是我的代码 package com.someurl.www.myobservable; import android.support.v7.app.ActionBarActivity; import... -
1 votesanswersviews
如何在rxjava中添加常见的观察者
我是rxjava的新手,刚开始学习它并将我们的android项目转换为rx . 所以我编写了observable并使用flatmaps将它们链接起来调用apis并返回一个observable . 现在在主要活动中,我订阅了它们并将我的UI代码添加到onNext,onSubscribe,onComplete和onError(如果适用) . 但是我有多个api,我为每个api创建了一个observab... -
5 votesanswersviews
RxJava2在调用完成或错误时是否会自动处置observable?
我对RxJava的处理有疑问 . 我在Github上的RxSwift文档中找到了这个句子 . 当序列发送完成或错误事件时,将释放计算序列元素的所有内部资源 . 要立即取消序列元素和免费资源的生成,请在返回的订阅上调用dispose . 如果我理解正确,资源(observables)将在他们调用 onCompleted 或 onError 后被释放 . 所以问题是,RxJava是否像RxSwif... -
2 votesanswersviews
改造RxAndroid为api调用制作包装器
我想在改造中为api调用创建一个包装器,这样我就可以在常见位置显示ProgressDialog并处理常见的响应 . 我通过创建这样的包装来实现这一目标 public static <T> Observable<T> callApiWrapper(final Context context, ... -
1 votesanswersviews
如何在使用rxAndroid时获得改造响应?
我正在关注这个tutorial . 虽然我已成功采用rxAndroid来避免由循环视图引起的 Exception ,但我正在从改造中丢失 Response 对象 . 我最初的要求是...... interface UserRepo { @GET("user") fun get(): Call<User> } // then call it by u... -
1 votesanswersviews
RxAndroid运算符重试何时被调用但不重新订阅
使用Retrofit的API类 class interface TestApi { @GET("/path/abc/xyz") fun get(): Single } UseCase类 fun getResult(): Single { return testApi.get() .map{ response -> ... -
224 votesanswersviews
rxJava调度程序用例
在RxJava中有5 different schedulers可供选择: immediate():创建并返回一个在当前线程上立即执行工作的Scheduler . trampoline():创建并返回一个调度程序,该调度程序对当前工作完成后要执行的当前线程进行排队 . newThread():创建并返回一个Scheduler,为每个工作单元创建一个新的Thread . computation... -
1 votesanswersviews
将Arraylist转换为Observable列表而不创建一个全新的列表类?
我有一个 Arraylist<Object> ,我正在尝试使用 rxJava 使其成为 Observable 所以所有操作,如清除,添加和删除等,我可以得到听众 . 我看到这篇文章post为添加事件添加一个观察者 . 任何人都可以告诉我有没有任何方法直接将我的ArrayList转换为Observable列表,而不是创建一个可观察的列表类并为其创建所有方法,并将所有 newArrayLi... -
0 votesanswersviews
RxAndroid Observable填充子列表
所以我意识到 Headers 有点模糊,但我遇到的问题非常复杂(至少对我而言) . 我有一个Observable从API加载一个列表 . 用户响应类似于: { "status": "Successful", "count": 2, "response": [{ "_id... -
0 votesanswersviews
何时创建JavaRx observable,它向所有订阅者发出同步(或阻塞)列表?
我对RxJava,android和Java都很新...我正在尝试创建一个发出同步List的observable . 哪里错了? public class CurrentLocationHolder { private List<LocationPoint> locationBuffer = Collections.synchronizedList(new ArrayList&... -
79 votesanswersviews
使用Rxjava Schedulers.newThread()和Schedulers.io()进行改造
在 Retrofit 网络请求中使用 Schedulers.newThread() vs Schedulers.io() 有什么好处 . 我见过很多使用 io() 的例子,但我想了解原因 . 示例情况: observable.onErrorResumeNext(refreshTokenAndRetry(observable)) .subscribeOn(Schedulers.newTh... -
4 votesanswersviews
Schedulers.io()没有返回主线程
我正在使用RxParse来解析查询的异步加载但是当我使用subscribeOn(Schedulers.io())订阅我的observable时,我的onCompleted方法永远不会在主线程上调用 . 而不是这个,我的onCompleted方法在工作线程池内调用 . 如果我使用observeOn(AndroidSchedulers.mainThread),一切都会工作,但我的onNextMetho... -
0 votesanswersviews
rxJava错误捕获socketTimeoutException
我有一个可以通过改造生成的observable,我正在尝试实现错误处理,特别是连接超时 . 错误的订阅者被调用得很好,但应用程序仍然因sockettimeout错误而崩溃 . 有什么建议? Observable<History> history = api.returnHistoryRX(pair, String.valueOf(unixTime-3600), String.value... -
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... -
2 votesanswersviews
为RxJava和Retrofit定制onNext()实现
我正在使用RxJava和Retrofit,我正在尝试找到一种非常简洁的方法来抽象我的API调用,以便最大限度地减少Activity中的代码 . 到目前为止,我有这样的事情: Observable<SomeObservable> combined = Observable.zip(firstObservable, secondObservable, SomeObs... -
1 votesanswersviews
如何使用retryWhen()Rxandroid
我使用RXJava调用昂贵的递归函数 . 大部分时间它运行得非常快,但有时会产生太长时间 如果线程仍在运行,有没有办法可以在5秒后使用 retryWhen() ? observable = getObservable(); ///Runs a recursive function mObserver = getSudokuPuzzleObserver(); observable.subscr...