Kotlin协同线和Arrow是避免嵌套平面地图的好方法，在Kotlin中引入了一元理解。然而，Kotlin的Flow类型仍然依赖于声明式平面映射，因此我们进入了直接和声明风格的混合： return clientRepository.findByIdNotNull(page).asFlow()
.fl
浏览 7提问于2022-02-01得票数 2
回答已采纳
我有这些代码，我想让它变得更优化 我想我可以使用kotlin- flow的flatMapMerge，但我不认为应该如何将我的代码转换为flow val quiries = listof("s","使用flatMapMerge()的方法是什么？https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core&#x
浏览 163提问于2019-09-09得票数 1
从文档中看，并发不会对reactive、link生效 有没有人知道如何在不增加实例的情况下提高吞吐量？
浏览 23提问于2020-07-07得票数 0
回答已采纳
我想知道flatMapMerge在这段代码中是如何工作的： emit("$i: First")the start time .flatMapMerge我的问题是
让flatMap
浏览 2提问于2021-10-29得票数 0
回答已采纳
2回答
我正在寻找一种方法，以类似的方式链接几个流，因为操作是在RxJava中链接的。state ${it.javaClass}") }
在这个实现中，
浏览 11提问于2021-12-17得票数 2
回答已采纳
System.currentTimeMillis() val range = (1..10).asFlow() println("Elapsed time ${t2 -t1}")
private suspend fun triplicate(i: Int): FlowSystem.currentTimeM
浏览 6提问于2022-01-24得票数 0
回答已采纳
上下文让我给你举个例子。正如您所看到的，这个解决方案需要大量的样板代码，我认为使用Kotlin会使事情比使用RxJava更简单，但目前还没有这样的结果。因此，我可以像使用RxJava的catch()那样使用</e
浏览 9提问于2021-12-06得票数 3
回答已采纳
基本上，我必须使用OkHttp并行地向各种地址发出网络请求。我只关心第一次成功的结果。我可以在Kotlin上使用Flow执行此操作吗
我一直在四处寻找，但我一直在努力让请求并行运行，总是按顺序运行。编辑:我应该提一下，我计划在Android上使用这个。我可能可以用RX做到这一点，但我想学习Flow。我还试图限制我添加到应用程序中的库。编辑:我已经标记了一个正确的答案，但这不是我怎么做的，但它让我非常接近我是如何做的，但由于我是Flow的新手，我不知道我
浏览 22提问于2019-11-15得票数 2
回答已采纳
3回答
如何使用协程传递结果？
、、、
假设我有一个repos列表。我想遍历所有它们。当每个repo返回结果时，我希望将其传递。val deferredItems = mutableListOf<Deferred<List<result>>>()
deferredItems.add(async { getResult(repo) })deferredItems.fo
浏览 1提问于2020-01-04得票数 2
我已经将用户的数据与Room Database同步存储在Firebase Cloud Firestore中，用户的活动状态存储在Firebase Realtime Database中。在Datasource层，用户的数据以PagingDataFlow的形式公开，单个用户的活动状态以Flow的形式公开。从Activity/Fragment层来看，两者结合在一起形成了一个UI状态。现在，无论是在Repository中还是在ViewModel中，我都必须将这两者结合起来，形成UserUI单元，并将该流
浏览 15提问于2022-05-01得票数 0
1回答
我是这个kotlin协同流的新手，我想知道如何在流中实现并发，而根据它的文档，launch、scope和withContext不能在流中使用。如果没有这个，我如何才能在kotlin flow中实现并发性？
有人能帮我吗？
浏览 2提问于2020-04-06得票数 2
回答已采纳
1回答
我正试图弄清楚如何处理这样一种情况:在您的某个阶段中，您需要发出一个返回InputStream的调用，在那里，我会将该流作为一个进一步下降的阶段的源来处理。结果将是巨大的大部分时间，所以我可以收集所有的东西在记忆中。
浏览 2提问于2017-09-02得票数 0
回答已采纳
1回答
我有一个来自像这样的web套接字的akka流，并且希望构建一个可重用的图形阶段(inlet：这个流，FlowShape：添加一个额外的字段到JSON中，指定原点：...,
implicit val materializer = ActorMaterializer(
浏览 2提问于2017-05-02得票数 0
回答已采纳
我正在尝试从RxJava切换到Kotlin Flow。Flow真的令人印象深刻。但是现在kotlin Flow中有没有类似于RxJava的"GroupBy“的运算符呢？
浏览 23提问于2019-10-30得票数 7
在可流动的RxJava 2中，有不同的背压策略，其中最有趣的是：
在Kotlin有Flow，它宣称它有背压支持。通过使用以下方法，我能够创建具有缓冲区和最新策略的流：observeFlow() .collect { ... }observeFlow简而言之，当之前的值尚未处理时，DROP将删除流中的任何值。有了流程，我甚至不确定这是可能的。.backpressureDr
浏览 5提问于2020-01-25得票数 5
回答已采纳
我正在尝试使用Kotlin Flows为我的API调用实现先缓存后网络的策略。我的期望是我应该从缓存中获得第一个事件，然后在几毫秒后从服务器中获得第二个事件。在本例中，"Response Received"被打印了两次，但是一个接一个地立即打印。在这个变体中，"Response Received"只打印一次，即在getDataFromServer()返回之后。<Data> .collect {
Timber.i(&q
浏览 0提问于2020-02-13得票数 10
我从Kotlin调用一个返回未来的Scala类，我可以等待它的未来 val future: Future<String>future, Duration.apply(10, TimeUnit.SECONDS))}
但我真正想要的是能够实现onComplete回调，并将该值传递给KotlinChannel或Flow，以便在另一个coroutine中使用，因此我不会阻塞任何线程。知道如何
浏览 8提问于2020-08-22得票数 2
回答已采纳
这是Youtube API ): Flow<ApiResponse<PlaylistItemsResp
浏览 7提问于2021-03-04得票数 0
在我的应用程序中，我使用Kotlin Flow。之前我在EspressoIdlingResource.increment()中使用了挂起函数，但它不适用于Kotlin Flow。如何解决这个问题？
浏览 32提问于2021-02-12得票数 1
回答已采纳
2回答
如何在java中收集协程流？
、、、、
我在kotlin做了，没有问题。fun getDeepLinkFlow(): Flow<HashMap<String, String>?> = flow {} println(deep
浏览 21提问于2020-05-28得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
