rx-java2 相关问题

与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。

RxJava与android存储库模式

我使用RxJava与存储库模式,Room作为数据库和Retrofit从api获取数据。这是我的Dao @Dao公共界面SubjectDao {@Insert(onConflict = OnConflictStrategy ....

回答 1 投票 2

使用RxJava分叉任务并组合结果

我正在尝试执行以下操作:A | | V Observable ......

回答 1 投票 2

可观察不重复

我试图在一个observable中重复()一个动作,但它不会多次执行它。 Observable.create(new ObservableOnSubscribe (){@Override public void ...

回答 1 投票 1

CombineLatest,观察多个检查按钮Rxjava

我创建了自定义按钮,它有内部检查的监听器,并在PublishSubject的帮助下将其公开为可观察对象。公共类SwitchItem扩展LinearLayout实现SwitchButton ....

回答 1 投票 0

使用gson,改进将json数组反序列化为模型的正确方法

我使用gson将http响应(来自改造)反序列化为模型。所以,现在我有一些json数组作为响应,如下所示:[{“object”:“value”},{“object”:“value”},{“object”:“value”},{“...

回答 1 投票 0

根据Flowable的返回值获取Single并合并结果

我调用了一个返回Flowable的方法 >。对于此列表中的每个实体,我想调用一个返回相关Single的方法 。实体和......

回答 1 投票 0

SubscibeOn对主题没有影响

根据我的理解,SubscribeOn运算符指定Observable源应该开始发射的Thread。如果链上有多个SubscribeOn,则第一个生效...

回答 1 投票 2

RxJava而不是Retrofit回调

我是新手使用RxJava,我对如何在RxJava上从Retrofit更改我的新Callback有疑问?我的工作代码在这里:服务服务=新的Retrofit.Builder()。baseUrl(“...

回答 1 投票 0

如果适配器的数据通过RxAndroid设置,则RecyclerView在返回导航后滚动到顶部

当我直接设置适配器的数据时,从detial片段返回后列表的滚动位置是正确的,但如果我使用RXAndroid来处理数据,则滚动总是跳转到...

回答 1 投票 3

当stream2基于stream1时,如何避免两次订阅stream1的.zip(stream1,stream2,BiFun)?

我在android中使用firebase和一些复杂的数据。我需要保存引用,我的zip操作或者我整体处理RX的方式都有问题。我想创建一个新的A对象......

回答 1 投票 0

RxJava2没有数据的主题

我必须听一些事件,这可能发生在许多地方,如按钮点击,textChanged,活动回调等。我正在使用Subject来触发此事件。但我不想发送任何数据......

回答 1 投票 1

RxJava和Kotlin数据类copy()操作中的线程切换成本

我的问题是关于操作的成本,特别是Kotlin数据类copy()操作和RxJava observeOn()线程切换的成本。我有一个系统可以让我们说...

回答 1 投票 0

RxJava:如何包装多步操作,将步骤完成返回给观察者?

假设我有一个登录和用户数据方法,表示HTTP调用:Single 登录();单 用户数据();我需要调用login()然后调用userData()。如果两者都成功,......

回答 1 投票 1

在RxJava的doOnSuccess运算符中调用了单元测试验证方法

我有以下代码我正在尝试单元测试:if(networkUtils.isOnline()){return remoteDataSource.postComment(postId,commentText).doOnSuccess(...

回答 1 投票 1

Room Flowable不会在插入时发出数据

我很难理解Flowable在Room中的工作原理。我有这样的Dao方法@Insert(onConflict = OnConflictStrategy.REPLACE)void upsert(List 网站); @Query(“SELECT * ...

回答 1 投票 1

调用doOnSubscribe时,RxJava2 PublishSubject没有观察者

我正在使用RxJava2。我有一些可观察的,很少有订阅者可以订阅它。每当新订户到达时,应该完成一些工作,每个订户都应该......

回答 1 投票 0

Rxjava 2与相机异常

我只是将我的代码从asynctask切换到rxjava2并且我在我的nexus上随机获取此异常:在Galaxy s6 Edge中调用Camera.release()之后正在使用相机以下是我的...

回答 1 投票 7

如何在onComplete之后显式取消订阅observable

在下面的代码中,在完成onComplete之后,unSubscribe如何以及在何处明确地显式地取消订阅Observable? getObservable()。observeOn(AndroidSchedulers ....

回答 3 投票 3

跟踪specifec zipped使用Rxjava zip运算符时出现Observable错误

如果我有一个案例,我使用Rxjava zip运算符,让我们说它拉链4个不同的网络调用。例如:Observable.zip(networkCall1,networkCall2,networkCall3,networkCall4),(model1,model2,...

回答 1 投票 0

选中为true时,Recycler View项目中的复选框立即被检查为false

我使用RxJava2,Kotlin和Room作为我的例子。这是用于将我的项目填充到recyclerView的适配器:class ShoppingListDetailsAdapter(val list:ArrayList

回答 2 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.