回答情况：
提问时间：
问题标签：
1回答
什么是并行运行多个Monix任务，然后得到一个结果的最佳方法？val b: Task[B]
case class ResultClass(a:A, b:B
浏览 3修改于2020-03-18得票数 1
回答已采纳
2回答
我想为monix.reactive.Observable写一个拆分函数。import monix.eval.TaskLikeimport monix.reactive.{Observable, Observer}
import scala.concurrent.Futureimport monix.reactive
浏览 33修改于2019-09-13得票数 4
我正在尝试将(String，Date)的一个可观测对象拆分为两个不同的可观测对象，并将它们压缩在一起，如下所示 at monix.reactive.Observable$$anon$6.subscribe(Observable.scala:155)
at monix.reactive.Observable$$anon$5.unsafeSubscribeFn(Obse
浏览 11提问于2018-02-07得票数 4
回答已采纳
我正在尝试使用Monix可观察到的方法将文件的大内存控制成更小的字节块，这样它就不会消耗太多的RAM来加载文件的字节。
浏览 1修改于2020-04-29得票数 0
回答已采纳
我想将Monix Observable与Doobie (fs2)流一起使用，但似乎无法正常工作。{Blocker, ContextShift, ExitCode, Resource}import monix.eval.TaskApp}import fs2.interop.reactivestreams._
import monix.reactive.Observable
浏览 20提问于2020-08-23得票数 1
我正在努力学习Scala，并且玩得很开心，但我遇到了这个经典的问题。它让我想起了NodeJS早期的许多嵌套回调地狱。获取一个S3桶列表的任务。任务一完成后，要对桶的处理进行批次处理。每个批的：获取每个桶的区域。过滤出不在该区域的桶。<code>H 210</code><code>H 111</code>列出每个S3中的所有对象--<code>H 214</code><code>G 215</code>
在某种程度上，我得到了一个类型：Task[Iterat
浏览 4修改于2020-05-16得票数 0
回答已采纳
在我早期的的基础上，并根据的见解，我的目标是将get请求发送到给定的url，并使用Monix的节流特性来划分请求(以避免访问速率限制)。到目前为止，我已经尝试过这样做(下面是我实际代码的一个简化片段)：import monix.eval.Taskimport sttp.client.https://heloooo.free.beeceptor.com&
浏览 5修改于2020-08-09得票数 1
回答已采纳
这里有一个片段说明了我的问题：import monix.execution.Scheduler.Implicits.globalimport monix.reactive._
//real case fetch next node
浏览 5提问于2017-12-25得票数 0
回答已采纳
Monix使用Ack同步发出的消息，但是如果我使用groupBy和flatMap，内部可观察到的不跟随来自source的背压。请参阅此测试代码：importmonix.execution.Ack.Continue
import monix.reactive.Monix版本："io.monix"
浏览 2修改于2019-04-26得票数 4
回答已采纳
如何使用Monix任务从一系列任务(可以并行运行)编写单个输出流:例如，我有N个任务可以并行运行，并从HTTP call/server,获得一些响应，我正在将响应写回文件流(就像有限制内存一样)，但我得到stream closed error,想知道是否有一种方法可以使用Monix任务或任何其他API来实现这一目标。{FileOutputStream, OutputStream, OutputStreamWriter}
import monix.ex
浏览 0提问于2019-06-20得票数 0
回答已采纳
我目前正致力于实现对API的客户端http请求，并决定探索用于此任务的sttp & monix。由于我对Monix还不熟悉，所以我仍然不知道如何运行任务并检索它们的结果。下面是我到目前为止尝试过的一个片段：import sttp.client.asynchttpclient.monix._ Task.parSequenceUnordered(tasks).guarantee(
浏览 1修改于2020-08-05得票数 2
回答已采纳
就像monix.reactive.subjects.BehaviorSubject.onNext(_)
import akka.stream.scaladsl.{Flow, Sink, Source}import monix.execution.Scheduler.
浏览 4修改于2020-03-05得票数 1
回答已采纳
让我们假设我想通过一个名为pid的公共字段检索一些项import monix.execution.Scheduler.Implicits.globalimport com.datastax.driver.core.Row
import cassandra.src.CassandraHelper
浏览 10修改于2017-08-28得票数 0
回答已采纳
Monix可观察到的apis有.onErrorRestartIf(f: Throwable => Boolean)和.onErrorRestart(times: Int)。
浏览 5提问于2017-07-10得票数 0
回答已采纳
我正在尝试使用monix 3.0.0-RC1构建反应式应用程序。 例如，a有一个Int的序列，而第二个元素是错误的。
浏览 25提问于2019-04-10得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号