1回答
Monix任务中为空
、、、
在Monix Task中有类似的东西吗？list.isEmpty) Mono.empty[T]() })
} 在这里，我试图从一个项目列表中提升一个项目，在这个列表中，我不想发送像Mono.just(List())这样的东西，因为这将需要我在db调用端添加另一个空/null检查。
浏览 19提问于2019-03-15得票数 0
我目前正致力于实现对API的客户端http请求，并决定探索用于此任务的sttp & monix。由于我对Monix还不熟悉，所以我仍然不知道如何运行任务并检索它们的结果。我的目标是获得一系列http请求结果，我可以在并行->解析->加载中调用这些结果。._import monix.eval.Task
val如
浏览 1提问于2020-08-05得票数 2
回答已采纳
1回答
当所有异步任务超过阈值时停止吗？
、、、、
场景我的解决方案 import monix.eval.Task import scala.concurrent.duration._
import monix.exe
浏览 3提问于2020-02-16得票数 3
回答已采纳
我无法理解为什么添加executeWithFork会阻止任务在下面的示例中运行： implicit val scheduler
浏览 0提问于2019-01-18得票数 1
回答已采纳
1回答
我目前正在学习和玩STTP使用Monix后端。在处理完所有请求(每个请求都是一项任务)之后，我主要是关闭后端。我创建了示例/模拟代码以类似于我的问题(据我理解，我的问题更一般，而不是特定于我的代码)：import monix.eval.Task") .response(asString)
.send(
浏览 14提问于2020-08-09得票数 1
回答已采纳
只需尝试一些简单的任务示例。以下代码工作正常import monix.execution.CancelableFuture case Left(err) => System.out.println(s"ERROR: ${err.getMessage}")但是，使用runToFuture只在沙箱中工
浏览 8提问于2020-09-28得票数 0
回答已采纳
1回答
我有一个项目文件，其中包括一个jar文件(monix.jar)和一些数据(模型、插件、.)。开发人员没有提供它的源代码，我需要运行它。我正在eclipse中工作，我尝试了以下步骤：
将主选项卡中的位置设置为然后将Working Directory设置为项目文件夹的路径。D:\eclipse工作区\monix</
浏览 5提问于2016-11-06得票数 0
1回答
在我早期的的基础上，并根据的见解，我的目标是将get请求发送到给定的url，并使用Monix的节流特性来划分请求(以避免访问速率限制)。到目前为止，我已经尝试过这样做(下面是我实际代码的一个简化片段)：import monix.eval.Taskimport sttp.client.Aug 08 18:50:21 CEST 2020)
//(https
浏览 5提问于2020-08-08得票数 1
回答已采纳
2回答
我刚刚开始使用monix，部分原因是为了在一个长期运行的应用程序中安排重复的工作。我将管理异常，但我希望这个monix继续调用给定的函数，即使我允许传递其中的一些函数。编辑：现在，我不认为在Monix中有任何功能可以做到这一点。所以我得自己去做。如果某人有同样的问题，如果有人知道一个可能有用的monix工具，我就让这个问题解决。
浏览 2提问于2018-09-12得票数 0
回答已采纳
我有一个调度容易出错的任务的 Scheduler：import monix.eval.Task throw new Exception() .unsafeRunSync()问题是--如果调度器中的任务抛出异常当使用Task时
浏览 7提问于2018-07-14得票数 1
我正在使用monix任务，我试图捕获一个Throwable，然后转换为一个自定义错误。我已经删除/更改了代码，使其简单且相关。这是代码(在代码片段之后的问题)：import monix.reactive.Observableimport monix.eval.Task
private[this]
浏览 8提问于2017-11-19得票数 2
回答已采纳
我试图使用monix对某些操作进行并行化，然后执行错误处理。现在，这些方法中的每一个都评估一些条件并返回一个任务。，为Y。根据这两个任务中的哪个失败，我只能在onRecover输出的parMap2方法上得到两个失败中的一个。
如果两者都失败了，我只会得到任务X的错误。我是否有可能以完全异步的方式完成我使用Monix所做的工作(例如，其他一些方法可以一起组合任务)？或者，我是否必须阻止执行人员，单独获取错误并重新组合值
浏览 9提问于2021-07-27得票数 2
回答已采纳
我的rest点只是返回一个空的条目数组，因为它不等待查询的完成。让我们假设我想通过一个名为pid的公共字段检索一些项import monix.execution.Scheduler.Implicits.globalimport com.datastax.driver.core.Row
import cassandra.src.CassandraHelperitemList ::= ItemMapper
浏览 10提问于2017-08-26得票数 0
回答已采纳
我有以下两段用Scala/Monix编写的代码： for { b <- task2(a) val b = task2(a).runSyncUnsafe}
我认为f1版本更好，因为它完全异步，它不会阻塞线程，我的假设是，如果有很多任务在运行，第一个任务在多线程中应该表现得更好。另外，在我们的特定情况下
浏览 6提问于2018-10-04得票数 0
2回答
如何处理异步执行任务期间的失败？也就是说，至少打印堆栈跟踪并关闭。下面的代码似乎永远等待输入>5。val things = Range(1, 40) def t(i:Int)
浏览 10提问于2019-10-20得票数 1
回答已采纳
1回答
现在让我们想象一下，我们正在处理REST服务，我们的场景是：
我们希望在一个事务中执行所有这些步骤。问题是，如果没有transactor.trans()为我们提供的自然变换，我们将在两个monads中工作-- Task和ConnectionIO。这不可能。问题是-如何将doobie ConnectionIO与1组合中的
浏览 1提问于2018-05-22得票数 17
回答已采纳
我尝试按键在Monix中执行单个Observable的拆分，然后对每个GrouppedObservable中的最后一个n事件进行分组，并将它们发送给进一步处理。Monix中的方法有参数keysBuffer，指定如何处理密钥缓冲区。下面是描述用例的简化版本。import monix.execution.Scheduler.Implicits.global
i
浏览 5提问于2019-01-06得票数 4
1回答
=> Task.parSequence(chunk))
}
我有一个Play控制器，在这里调用这个函数并运行任务如何调整任务实现以满足我的需要？有什么想法吗？我尝试了onErrorRecoverWith处理程序，但似乎没有任何效果。有什么想法吗？
浏览 5提问于2021-03-21得票数 0
回答已采纳
我使用Monix定期执行一些任务。但我不知道如何不仅执行它们，还能从它们中收集结果.假设我有一个计划好的任务，每次返回一个随机数：implicit val io: SchedulerService_ + 2).map(println).executeOn(io).delayExecution(1.seconds).loopForever.runAsyncAndForget
从理论上讲，我可以在任务执行之前创建可变和并发列表，而在task
浏览 3提问于2019-08-07得票数 0
回答已采纳
2回答
在java中，我基本上会使用，并将其设置为5分钟。如果我想取消，我只需调用cancel方法。好的是，我可以在Scala中使用那个Java类。
浏览 2提问于2017-07-04得票数 0
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
