-
1 votesanswersviews
RxJava2问题：Zip并行处理多个服务时如何处理错误？
假设我们有3个服务，employeeTitle，employeeName，employeeLocation . 如果所有服务三个服务抛出employeeTitle错误，employeeName和employeeLocation只会抛出1个错误？根据文档，这应该是行为是正确的吗？如果只有employeeTitle抛出错误而其他服务成功，会发生什么？根据我的理解，如果employeeTitle抛出异常... -
0 votesanswersviews
RxJava2：并行调用多个服务时Zip如何处理错误？
假设我们有3个服务， employeeTitle ， employeeName ， employeeLocation . 如果所有服务三个服务抛出错误 employeeTitle ， employeeName 和 employeeLocation 服务只会抛出1个错误？根据文档，这应该是行为是正确的吗？如果只有 employeeTitle 抛出错误而其他服务成功会发生什么？根据我的理解，如果 e... -
1 votesanswersviews
rxjava长链中的StackOverflowError异常
我用很多运算符构建了很长的rxjava链（带有改进请求）：doOnNext，doOnError，switchIfEmpty，onErrorResumeNext，flatMap在某些设备上（例如Android 4.1），当链路经过最长路径时，它会抛出StackOverflowError异常 . 是否有一些方法或最佳实践来优化链或防止StackOverflowError？ 现在我只看到一种方式 - 中... -
2 votesanswersviews
如何使用RxJava2创建2个或2个并行网络请求？
我用Retrofit 2.0创建了两个不同的API请求 Observable<T> getOrganisationList() Observable<T> getStaffList() 我正在使用包含多个其他一次性用品的 CompositeDisposable 容器 . 我希望上述两个可观察请求并行执行 . Please, answer the question with... -
0 votesanswersviews
RXJava忽略错误并继续链
我有一个RXJava链，可以抛出错误 . 我希望链继续并忽略错误并达到订阅，仅针对某些特定错误 . 例如，在此代码中 authDataManager .getUserAccessToken(username, password) .subscribeOn(Schedulers.io()) ... -
0 votesanswersviews
RxAndroid Observable填充子列表
所以我意识到 Headers 有点模糊，但我遇到的问题非常复杂（至少对我而言） . 我有一个Observable从API加载一个列表 . 用户响应类似于： { "status": "Successful", "count": 2, "response": [{ "_id... -
0 votesanswersviews
在Observable创建之前订阅Rx
在该项目中，有许多模块 . 每个模块可能想要接收从其他模块/模块发出的数据 . 试图解决的问题是，当我们订阅一个可观察的A时，这个可观察的可能还没有被创建 . 为了解决这个问题，讨论了两种方法： 有一个Observable Registry单例 . 每当一个observable准备就绪时，将一对放入注册表，并通知所有模块注册表已更改 . 每个模块都会收听此通知，并确定它是否是您感兴趣的更改 .... -
0 votesanswersviews
何时创建JavaRx observable，它向所有订阅者发出同步（或阻塞）列表？
我对RxJava，android和Java都很新...我正在尝试创建一个发出同步List的observable . 哪里错了？ public class CurrentLocationHolder { private List<LocationPoint> locationBuffer = Collections.synchronizedList(new ArrayList&... -
2 votesanswersviews
根据条件从列表中创建Observable
我是RxJava的新手，所以我在努力做这种事情，事情就是这样 我有一个Observable从另一个名为Gatekeeper的类发出List映射，如下所示： List<ParkappGate> actualgates = Observable.just(gates).concatMap(new Func1<List<Gatekeeper>, Observable<... -
3 votesanswersviews
Kotlin - 如何创建RxJava flatmap（）的别名函数？
我尝试为 Flowable.flatmap() 创建一个别名函数，如下所示，但编译错误 . fun <T, R> Flowable<T>.then(mapper: Function<T, Publisher<R>>): Flowable<R> { return flatMap(mapper) } 错误是： One type argu... -
0 votesanswersviews
RxSwift flatMapLatest没有处理以前的observable
我正在使用RxSwift Playground：https://github.com/ReactiveX/RxSwift 我实现了以下示例代码来建模一个简单的异步任务，将一个Observable of Int转换为一个Observable of String： let pubishSubject = PublishSubject<Int>() pubishSubject.asObser... -
4 votesanswersviews
RxJava：“java.lang.IllegalStateException：只允许一个订阅者！”
我正在使用RxJava来计算Android中某些传感器数据的标准化自动关联 . 奇怪的是，我的代码抛出一个异常（“java.lang.IllegalStateException：只允许一个订阅者！”）并且我不确定该怎么做：我知道GroupedObservables在订阅我的多个订阅者时可能抛出此异常，但是我不认为我在任何地方使用这样的东西 . 您可以在下面找到（最有可能）触发异常的方法： publ... -
5 votesanswersviews
验证在RxJava订阅服务器的onNext中调用该方法
我有以下方法使用Retrofit服务接口从API获取一些数据，然后与 view 接口进行交互 . @Override @VisibleForTesting public void fetchPhotos(@Nullable PhotosService service, @Nullable Scheduler subscribeOn) { view.showLoading(); R... -
-2 votesanswersviews
Rxjava：我不打印
我不知道为什么这个程序不打印 . 我想要1秒钟打印字符串对象 . 所以我使用间隔 . 这个程序通常编译 . 但结果不打印 . 为什么？救命 . （我是韩国人 . 所以英语不成熟 . 对不起） public class main { public static void main(String[] args){ String str1 = "Apple&q... -
224 votesanswersviews
rxJava调度程序用例
在RxJava中有5 different schedulers可供选择： immediate（）：创建并返回一个在当前线程上立即执行工作的Scheduler . trampoline（）：创建并返回一个调度程序，该调度程序对当前工作完成后要执行的当前线程进行排队 . newThread（）：创建并返回一个Scheduler，为每个工作单元创建一个新的Thread . computation... -
0 votesanswersviews
每个Java Future控制其生命周期的核心
我正在使用web3j库在Java中为以太坊区块链开发一个Load Test应用程序 . 此库中使用的特定函数，异步发送事务，并返回Future对象 . 该库提供了许多功能，这些功能最初满足我对应用程序开发的所有需求 . 但是，在设计和重新设计负载测试应用程序之后，我注意到了一个问题 . 我只能同时部署N个Futures，其中N是我机器上可用内核的数量 . 这是非常低效的，因为每个事务至少需要10秒... -
1 votesanswersviews
Concat运算符语义，但是立即订阅所有不可见的observable
我想连接冷和热的可观察量 . 也就是说，得到的observable应该首先发出冷可观察的结果，然后是热的可观察结果 . 同时，我希望订阅第二个observable，即热门，在第一个订阅发生的同时发生，否则我会错过它的一个重要事件 . 这与 merge 会做的非常相似 . 但是我想保证热的观察者在冷的完成之前不会推动任何东西，而这并不能保证 . 什么是正确的方法？ -
9 votesanswersviews
是否有任何开发模式可以替换网络请求的IntentService？
在我与同事一起开发的当前应用程序中，我们使用IntentServices和Volley调用来处理RESTful API网络请求 . 它只是简单的JSON字符串数据和一些小图像 . 我对那些在处理网络请求方面经验丰富的问题是这样的：那里有更合适或更清洁的东西吗？ 根据我的理解，使用IntentService的优势在于它在主线程的后台运行，并且通常是Android OS杀死的最后一件事 . 缺点是In... -
233 votesanswersviews
什么时候应该使用RxJava Observable和Android上的简单回调？
我'm working on networking for my app. So I decided to try out Square' s Retrofit . 我看到他们支持简单 Callback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Pho... -
20 votesanswersviews
RxJava改造长轮询
我的问题是我无法通过 Retrofit 获得无限流 . 在我获得初始poll（）请求的凭证后 - 我做了初始poll（）请求 . 如果没有更改，则每个poll（）请求在25秒内响应，如果有任何更改，则每个poll（）请求更早 - 返回changed_data [] . 每个响应包含下一个轮询请求所需的 timestamp 数据 - 我应该在每个poll（）响应之后执行新的poll（）请求 . 这是... -
79 votesanswersviews
使用Rxjava Schedulers.newThread（）和Schedulers.io（）进行改造
在 Retrofit 网络请求中使用 Schedulers.newThread() vs Schedulers.io() 有什么好处 . 我见过很多使用 io() 的例子，但我想了解原因 . 示例情况： observable.onErrorResumeNext(refreshTokenAndRetry(observable)) .subscribeOn(Schedulers.newTh... -
1 votesanswersviews
用RxJava链接改装调用
所以基本上我要做的就是进行第一次网络通话 . 如果被调用的RESTful Web服务返回1，则进行第二次网络调用 . 如果Web服务返回0，则不进行第二次网络呼叫 . 这是我的代码 final ApiInterface apiInterface=restAdapter.create(ApiInterface.class); apiInterface.submitDataToAnalyze(&quo... -
1 votesanswersviews
rxjava链中的stackoverflowerror
我有一个rxjava链登录和下载联系人ect使用retrofit2 . 不过，我在android 2.3.3设备上获得了stackoverflower错误 . 反正有没有减少函数调用链？ W: java.lang.IllegalStateException: Fatal Exception thrown on Scheduler.Worker thread. W: at rx.intern... -
2 votesanswersviews
Android mapbox：如何取消注册IntentReceiver？
mapView = (MapView) findViewById(R.id.mapview); mapView.onCreate(savedInstanceState); mapView.getMapAsync(new OnMapReadyCallback() { @Override public void onMapReady(MapboxMap... -
2 votesanswersviews
RxJava：无法为rx.Observable错误创建调用适配器
我所做的： public interface ApiInterface { @Multipart @POST("/android/upload/index.php") Observable<Response> postImage(@Part MultipartBody.Part image, @Part("nam... -
-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&... -
1 votesanswersviews
将响应返回为Flowable时，不会调用onComplete
我正在尝试使用retrofit和rxjava 2进行webservie调用 . 我正在探索两种不同的方法来使用RxJava2 . 问题是我得到回应，我使用 Observable 但它不适用于 Flowable . 使用 Flowable 时我没有打印日志我尝试调试它但它不会进入 onNext 或 onComplete 或 onError . 只有 onSubscribe 被执行 . 1）使用o... -
8 votesanswersviews
RxJava onErrorResumeNext（）
我有两个可观察对象（简称为A和B）和一个用户 . 因此，订阅者订阅A，如果A上有错误，那么B（这是后备）就会启动 . 现在，每当A遇到错误B被称为罚款，但是A调用订阅者的onComplete（），所以B响应即使B执行成功，也永远不会到达订户 . 这是正常行为吗？我认为onErrorResumeNext（）应该继续流并在完成后通知订阅者，如文档（https://github.com/Reactive... -
4 votesanswersviews
Schedulers.io（）没有返回主线程
我正在使用RxParse来解析查询的异步加载但是当我使用subscribeOn（Schedulers.io（））订阅我的observable时，我的onCompleted方法永远不会在主线程上调用 . 而不是这个，我的onCompleted方法在工作线程池内调用 . 如果我使用observeOn（AndroidSchedulers.mainThread），一切都会工作，但我的onNextMetho...