我在科特林和RxJava一起工作。我有一个函数，transform(f: Foo): Single<Bar> 如何获取Foo的List，并对每个next执行transform，以获得Flowable<Bar>的结果，其中Flowable中的每个next都是调用transform的结果 基本上，我需要一个函数 fun getFlowable(foos: List<Foo&
浏览 8提问于2020-01-17得票数 0
回答已采纳
1回答
让我们使用这个可观察到的模拟来简化：这将返回true以模拟成功的响应。我想继续逐行发送，在发送另一个之前等待一个成功的信号。
这有可能吗？什么是最干净的解决方案？
浏览 0提问于2021-08-04得票数 0
我试图得到一张信息地图，其中有一个作者id键，如下所示：这就是我尝试过的： Collection<Message> messages = longCollectionMap.get(0);方法messageViewModel.getAll()返回：因此，我将其转换为
浏览 0提问于2019-01-08得票数 0
回答已采纳
这是非常基本的，但我对RxJava非常陌生，无法为我所拥有的查询找到合适的解决方案。
查询就像，我得到了一个可流动的列表(单个流)，并希望再次将其转换为新的可流动(而不是逐项可观察到)，作为初始列表。在转换为新的可流动列表时，每个项目都应该有最后项的累积和。cumulativ
浏览 2提问于2020-10-12得票数 0
回答已采纳
假设我有一个在应用程序的不同部分之间共享的可流动的。在我希望观察的每个片段中，我将其转换为带有LiveData的LiveDataReactiveStreams.fromPublisher，以避免泄漏和崩溃。现在我有了一个包装我流动的LiveData。现在，这是一个可流动的包，
浏览 2提问于2017-12-19得票数 9
回答已采纳
1回答
List<Action> handle() {} executeActionsAsync(actions) { action.forEach(functionexecuteAsync(actions);}
我想在RXJava2中做同样的模型。任何帮助都是非常感谢的。
浏览 0提问于2018-09-18得票数 8
3回答
我有一个表单，看起来是这样的：在new_post_form_submit函数中，我想选择所有名为post_photo_edit的元素作为一个集合。正如您所看到的，它的名称实际<
浏览 4提问于2011-04-06得票数 2
回答已采纳
我仍然没有找到一种在AkkaStreams中进行“过滤”流的简单方法。用fromFunction做“映射”流对我来说是很清楚的，但是进行过滤不是很清楚。在RxJava/反应器中，有一个关于可流动/可观测的组合操作符，它将一个函数从一个可流动的函数转换成另一个可流动的
浏览 0提问于2020-02-06得票数 1
回答已采纳
1回答
使用ui-滚动显示非常长的文本(在MBs中)的最佳方法是什么？文本以数组的形式可用，但需要像文本区域一样以长文本文档的形式显示。我使用ui-滚动，因为文本中的每个单词都是一个可点击的锚标记。用户界面滚动td显示每个单词为列，行为行是唯一的方式吗？
我有一个包含> 2000元素(words)的大型数组，用户可以动态地更改它(<e
浏览 1提问于2020-01-31得票数 2
我在@Dao中有一个函数。让我们称其为DaoClass类现在，我想检查返回的数据列表是否为空。我仔细研究了DaoClass_Impl (在构建时生成)，发现可流动的不会是空的。所以,
getData().isEmpty将始终返回false。所以，如果返回的<
浏览 0提问于2018-07-02得票数 0
回答已采纳
我使用空间创建我的应用程序的本地数据库。假设我有一个实体调用用户和一个UserDao。看起来是这样的：interface UserDao: BaseDao<User>{ fun getUser(remoteId : Long) : Single<User>在这一点上没有什么奇怪的，
浏览 0提问于2018-03-02得票数 2
回答已采纳
我对kotlin观察点有一个问题，我已经通过互联网和stackoverflow搜索过了，但我认为我在概念上遗漏了一些东西。我有一个名为getCallsCountForWeek的dashboardRepository，它基本上返回了过去7天的可流动列表，现在我需要迭代所有的可流动对象，然后用用户当天的调用次数更新我的图形。Fina
浏览 18提问于2020-09-04得票数 1
DAO类和执行操作的所有必要方法，我想知道如何使用存储库中的可流动或可观察操作符来获取数据。下面是我的代码：@Daovoid insert(User user);
@Query("SELECT
浏览 0提问于2019-07-19得票数 0
我有一个InfiniteContainer列表，其中每个元素都是一个相对复杂的容器，每个元素都有几个不同的按钮，每个按钮都有各自的操作。因为它是一个可滚动的列表，所以我使用LongPointerPress来激活拖放，就像Shai在另一篇文章中推荐的那样。为此，我需要设置<em
浏览 0提问于2016-05-21得票数 1
我使用的是RxJava2，并且有一个类似下面这样的可流动函数 .doOnNext() .onErrorReturnItem() } .flatMap()
在zipWith操作符中，我的条件根据结果返回不
浏览 8提问于2017-02-27得票数 1
我需要停止主线程，并获得停止流动的可能性。我使用主线程没有停止，但是我得到了Disposable，我可以用它来停止所有流.blockingSubscribe();但是它似乎找到了一个更好的方法来阻止所有的流动
还有另一种方式，停止主线程并有可能停止所有可流动的<
浏览 4提问于2021-01-28得票数 0
回答已采纳
Ruby有一个方便的可枚举函数，称为。它“迭代每个连续元素数组的给定块”。这真的很不错。除了这绝对是一个each方法，它在完成时返回零，而不是像map那样循环的值数组。但是，如果我需要迭代一个可枚举类型，获取一个元素及其缺点，然后对它们执行一些操作并将它们返回到一个数组中，那么我能做什么呢？通
浏览 2提问于2017-12-02得票数 6
回答已采纳
我想使用selenium来测试web应用程序中每个可能的用户操作。例如，在pageA->pageB->pageC->pageD; pageA->pageB->pageE这样的应用程序中有两个路径，我们使用一个列表来存储pageB上的元素。我想使用一个for循环来测试这个列表中的每个元素。
问题是:测
浏览 1提问于2013-11-19得票数 0
我被困在一个简单的任务上，我很确定我走错了方向。我只需要拿一张物品清单。我只能在50页前拿到商品，但我不知道确切的页数。因此，我需要做的是调用并重复它，直到我得到少于50项(这意味着这是最后一页)，然后返回完整的列表，并在db中插入 localDataSource.insertItems(it)
浏览 2提问于2020-02-18得票数 0
回答已采纳
我想知道如何用适当的响应来处理这个HTTP请求。客户端是否等待贸易列表返回？(client (UI)必须对其进行操作，同时没有其他任何事情可做)。列表返回UI
CClass cclass =新CClass()；ExecutorService execSvc，我在操作</e
浏览 3提问于2012-04-04得票数 1
云服务器
ICP备案
云直播
对象存储
即时通信 IM
腾讯云开发者
