-
进行并行调用时,Zipkin跟踪ID消失了
我打了一些不同服务的电话。我计划并行运行它们。每个方法的输出均为Monix Task类型。 让两个对象使用 -
如何将Monix反应流转换为资源丰富的值并确保适当的发布?
我正在使用Monix反应流。 我有一组文件名<code>f: Observable[File]</code>,我想将其转换为打开的资源<cod -
Scala任务返回映射
我有一个方法readHeader,该方法带有一个参数并返回<strong> Task [List [Header]] </strong>,另一种方法要求多个I -
将列表[任务[列表[A]]]转换为任务[列表[A]]
如何在scala中将<strong> List [Task [List [Header]]] </strong>类型转换为<strong> Task [List [Header]] </strong>。 我 -
从NuProcess ByteBuffer创建可观察的Monix
因此,我目前有一个使用Java <code>Process</code>的项目,并且我正在尝试用NuProcess(即<a href="https://github.com/ -
Kamon跟踪ID因记录Monix Task值而丢失
我正在记录一个SQL查询,并使用版本3.9.2的com.typesafe.scalalogging的StrictLogging。 SQL查询是从Quill(io.getQuill -
并行执行Monix Task
并行运行多个Monix任务然后获得一个结果的最佳方法是什么? <br/> 我有以下任务,想获取一个ResultClass。 -
通过Monix进行扇入/扇出并发
我试图学习Scala并获得很多乐趣,但是我遇到了这个经典问题。它使我想起了NodeJS早期的许多嵌套回调地 -
Monix任务与Mongo Collection:错误处理
我正在尝试将Monix <code>Task</code>与<code>mongo-scala-driver</code>一起使用。我在理解<code>Error Handling</code> 时 -
Monix AsyncQueue在使用AsyncQueue.offer时由于类型不匹配而显示编译错误
使用monix文档中的此代码。如将n传递给queue.offer()所见,由于类型不匹配,代码无法编译。 <pre><code -
如何在处理速率限制时异步发送HTTP请求?
免责声明:我是<a href="https://github.com/softwaremill/sttp" rel="nofollow noreferrer">sttp</a>和<a href="https://monix.io/" rel= -
如何运行Monix的parSequenceUnordered,并处理每个任务的结果?
我目前正在努力实现对API的客户端HTTP请求,并决定为此任务探索sttp和monix。由于我是Monix的新手,所以 -
如何限制通过Monix发送HTTP获取请求?
以我先前的<a href="https://stackoverflow.com/questions/63254339/how-can-i-send-http-requests-asynchronously-while-handling-rate-limi -
完成请求后如何关闭STTP后端?
我目前正在使用Monix后端学习STTP并在其中玩耍。在处理完所有请求(每个请求都是一个任务)之后,我 -
在可观察的消耗完成之前,如何阻止程序终止?
我目前正在尝试使用Monix限制api get请求。我已经尝试过使用STTP的Monix后端,并且工作正常,直到完成后 -
通过Doobie 0.9.0可以正确使用Monix 3.2.2
我想将Monix Observable与Doobie(fs2)流一起使用,但似乎无法使其正常工作。没有流媒体,我的测试应用程 -
理解不同的单子
我有以下代码 <pre><code> def processInfoAndReturnResponse(input: Input]): EitherT[Future, CustomException, A] = ??? def sendMe -
相同的Scala Task代码在沙盒中可用,但在intelliJ中不起作用
只需尝试一些简单的Task示例。以下代码可以正常工作 <pre class="lang-scala prettyprint-override"><code><!DOCTYP -
猫效应可取消语义
我对 Monix 有一点了解,并且使用 <code>Cancelable</code> 像这样创建了 <code>Resources</code> 并带有某种簿记 <code -
在 Monix 中处理来自任务的错误
我有以下代码片段,可以对一组 URL 进行简单的 HTTP 查找。 <pre><code> def parse(filter: ParserFilter): Task[Seq[ -
使用 Monix 时,批量插入使用带有 mariadb 的 Quill.io 引发错误
在 mariadb 10.5.9 和 scala 2.13 上,使用 getquill.io 中的 <code>MysqlMonixJdbcContext</code> 并尝试使用进行批量插 -
在递归循环中处理和共享 Monix 任务的状态
我有以下代码递归迭代并通过网络执行某些操作。当它通过网络时,我想做一些优化,其中第一个优化 -
通过数据内容控制背压
我有一个 Monix Observable,它发出无限的数据流 <pre><code>case class Foo(id: String, value: Int) </code></pre> 我想 -
在这种情况下如何使用部分应用类型 Task.Create?
我在使用部分应用技术的对象 Task 下的 monix repo 中看到了这段代码。我知道当我们想一次推断 1 个类型 -
有没有一种简单的方法可以将 Option[Task[T]] 转换为 Task[Option[T]]?
在使用 <a href="https://monix.io/docs/current/eval/task.html" rel="nofollow noreferrer">monix.eval.Task</a> 或 <a href="https://zio.d -
使用 monix TaskApp
CE 2.x。莫尼克斯 3.4。第 1 行编译,第 2 行给出编译错误: cats.kernel.Order[A] 类型的发散隐式扩展 从 -
Monix 并行任务的错误处理(使用 parMap)
我正在尝试使用 monix 来并行化某些操作,然后执行错误处理 假设我正在尝试解析和验证这样的几