4回答
房间支持RxJava 3
、、、
我在项目中使用带有文件室的RxJava3，但收到以下错误下面是我收到错误的DAO接口方法Flowable<List<WishListMovie&
浏览 5提问于2020-06-14得票数 6
1回答
我想实现一些检测任何文件更改的代码(txt、doc、pdf等)。用RXJava触发一些任务。有可能吗？有什么建议吗？提前谢谢。
浏览 1提问于2018-11-06得票数 1
回答已采纳
我是RxJava2的新手，不确定是否正确使用它。
我有几个InputStreams正在从TCP流中读取数据，并且正在将数据读取到byte[]中。然后，我获取byte[]并为每个InputStream创建一个Flowable，然后将各个Flowable合并为一个。我希望能够关闭1个InputStream，但仍然可以让合并的Flowable继续从未关闭的InputStream读取。我的问题是，我
浏览 4提问于2017-07-12得票数 1
回答已采纳
对于下面的代码，我得到了以下错误：@DaoFlowable<List<Friends>> getAllFriends();
Observable<List<Friends&g
浏览 0提问于2018-06-16得票数 0
回答已采纳
我将如何开始一个基于条件的Completable链？ ...
fun getCachedThings(): Flowable&l
浏览 0提问于2018-11-27得票数 1
回答已采纳
2回答
偶然发现了不兼容的类型，错误的原因，我不明白。
.....
public <T extends Packet> Flowable<T> getPackets
浏览 0提问于2019-05-14得票数 0
回答已采纳
我刚刚开始考虑在Groovy v3中使用RxJava V3。当然，我倾向于从闭包开始。 但是RxJava subscribe ()方法不接受它们。我不确定的是，这是解决我问题的“最佳”Groovy方式。部分问题是Groovy闭包是一个抽象类，所以您必须扩展它。其次，我能找到“存储”提交的闭包的唯一方法是在这个具体的实现中有一个闭包引用。我不能理解的是，当你在编辑器
浏览 13提问于2020-03-14得票数 0
我正在将我们的应用程序从RxJava 1.x.x迁移到RxJava 2.x.x。我的一个方法有一个问题-它返回不同的返回类型。在RxJava2中，不允许使用可为空的可观察值。我用Optional解决了这个问题。我还用可流动的类替换了可观察的类，因为我需要管理背压策略。表示返回类型由Observable<PermissionsUsers?&g
浏览 1提问于2017-07-27得票数 0
1回答
房间+现场数据调试
、、、、
我正在尝试创建一个登录函数，它将检查db中是否存在用户名：- } msessionId.postValue("E"); return msessionId;
我被卡在检查用户的数据是否在房间DB中</e
浏览 1提问于2018-07-13得票数 2
回答已采纳
我使用的是干净的架构和MVVM模式，所以房间部分进入数据层，我将可观察对象从那里返回到域层，并通过将它们包装在LiveData中在表示层中使用它们。表示层中的Viewmodel： getTheIndexOfTopWord = null;
}
浏览 7提问于2018-08-30得票数 1
回答已采纳
1回答
上下文:要处理Flowable<Item>，我需要先处理第一个item，然后根据这一点，要么将所有项累加到单个项(reduce)中，要么对每个项应用一个简单的映射，而不累加(map)。我认为需要操作符知道当前元素是最后一个元素的一种方法。是否有这样的运算符知道当前元素是否是最后一个元素？我不能使用缓冲区，因为即使在不应该进行积累的情况下，它也总是获取2个元素。addData(item.getData()));
&#x
浏览 2提问于2022-05-08得票数 2
回答已采纳
3回答
无法查询使用领域
、、、、
我和RxJava一起使用领域，最后我想获取一个可以观察到的，我可以使用的：public Observable<List<Data>> getData_List() { = realm.where(Data.class).findAll().asObservable();这是我当前的代码，到目前为止，我收到一个错误，说明它们是不兼容<e
浏览 7提问于2017-02-05得票数 1
在Rxjava1中，我们可以订阅一个可观察对象，如下所示：Observable<T>.subscribe(asyncSubject不知道如何在Rxjava2 Flowable中实现同样的功能？我在想像这样的事情.doOnComplete { t -> asyncSubject.O
浏览 6提问于2019-07-23得票数 0
回答已采纳
我正在尝试使用rxjava和rxjava 2进行webservie调用。我正在探索使用RxJava2的两种不同的方法。问题是，当我使用Observable时，我得到了响应，但是它没有使用Flowable。当使用Flowable时，日志不会被打印，我试着调试它，但是它不会在onNext、onComplete或onError中运行。只有onSubsc
浏览 0提问于2018-04-30得票数 1
回答已采纳
如何将Stream<Path> s = Files.walk(root)从rxjava转换为Flowable？注意，我们不能简单地使用Flowable.fromIterable(()->s.iterator())，因为Files.walk抛出了IOException。最简单的方法是从Files.walk收集结果，然后从可迭代集合创建Flowable，但这似乎不是一种惯用的方法。
浏览 15提问于2019-06-10得票数 1
为什么我的编译器不允许自己在Observable上使用TestSubscriber订阅TestSubscriber<User> testSubscriber = new TestSubscriber<>();它说它不能解析接受这个参数的方法subscribe。但是在所有的RxJava测试教程中，他们使用</em
浏览 1提问于2017-04-06得票数 24
回答已采纳
我正在将一个Android Studio项目从使用RxJava 1.x切换到RxJava 2.x，并试图尽可能少地更改功能。该项目使用了Observables，在RxJava 1.x中是背压的。在RxJava 2.x中，Observable不再是背压的，但Flowable是，所以我将Observable的用法转换为Flowable的用法。但是，<
浏览 0提问于2017-02-03得票数 3
我在使用RXJAVA和RETROFIT的POST中得到一个HTTP500内部服务器错误，我不完全理解这个调用是如何工作的，但是另一个调用工作得很好，使用相同的BASE_URL常量。这是我的界面： Flowable<User
浏览 332提问于2019-11-01得票数 1
回答已采纳
我还在学习reactive/rxjava的一些细节，并对我经常遇到的一个用例有一个快速的问题。 我们经常有从DB或其他数据源获取条目的服务，并通过HTTP控制器将其返回给其他服务或客户端。我的问题大致是这样的:将数据公开为Flowable<DTO>和Maybe<List<DTO>> (或Single<List<DTO>>，如果合适)之间有什么实际区别吗？所有数据都将立即从数据源加载，因此它将在本地列表
浏览 20提问于2020-01-30得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
