scala-cats 相关问题

如何使用猫将 `NonEmptyList[Either[Error, User]]` 转换为 `Either[Error, NonEmptyList[User]]`？

我正在使用cats，想知道如何用它来转换数据： val data = NonEmptyList[任一[错误，用户]] 到 val 目标：Either[Error, NonEmptyList[User]] = howToConvert(data)

ScalaFX 和猫效应

我正在尝试将 Cats Effect 集成到 ScalaFX 桌面应用程序中，但在执行任务时遇到问题。我想运行后台线程/光纤来初始化窗口...

当我在 pom.xml 中明确声明非快照版本时，为什么 Maven 会下载数百个版本的 maven-metadata.xml 进行依赖？

在我的公司，我们正在升级到新版本的 Scala，但是当我在构建接近尾声时运行 mvn clean install 时，它花费了 22 分钟（！）尝试下载有关这些第三方的元数据

如何在不显式指定的情况下调用 Cats 类型类方法？

我想编写该代码： IO.foreverM: IO.sleep(1.秒) *> IO.println("Tick") 但它无法编译。然而这段代码编译： FlatMap[IO].foreverM： IO.sleep(1.秒) *&g...

处理 Scala FS2 流转换流程中的异常

导入 cats.effect.{IO, IOApp} 导入 fs2.Pipe 导入 fs2.Stream 对象测试扩展 IOApp.Simple { 最终案例类 Student(id: Int, name: String) private val StudentData: 地图[Int, Student]...

`=>` 在 scala 泛型中是什么意思？

阅读 Scalaz 和 Cats 的文档，我注意到它们经常在泛型/多态字段中使用 => 。例如，在应用程序的 scalaz 页面上，它具有以下内容

在 Scala 中获取当前的延续

Haskell 有一个获取当前延续的函数 获取CC = 调用CC

如何进行可取消的超时回调？

我希望用户可以运行带有回调的计时器并能够取消它。像这样的东西： def main: F[单位] = 为了 取消 <- runTimer(callback, 5.seconds) shouldCancel <- askU...

如何在 Scala Cats / FS2 中进行可取消的超时回调？

我希望用户可以运行带有回调的计时器并能够取消它。像这样的东西： def main: F[单位] = 为了 取消 <- runTimer(callback, 5.seconds) shouldCancel <- askU...

cats 和 scalaz 会给应用程序带来性能开销吗？

我知道这完全是一个无意义的问题，但由于我对编程技能的文盲，这个问题浮现在我的脑海中。 使用 Cats 和 scalaz，以便我们可以在 Scala 中编写类似于 Haskell/pure 的代码

`F[_]:Sync`中的`F`是什么，它来自哪里？

我想使用该存储库中的 cats-saga：https://github.com/VladKopanev/cats-saga 然而我被困在 OrderSagaCoordinator.scala L160 的那段代码上： def apply[F[_]: 同步:

有没有办法将资源元组转换为元组资源？

我正在尝试将 Scala2 / 无形代码移植到 Scala3，我错过的一件事是将资源的 HList 转换为单个类型安全的资源。 在 Scala2 中，我可以使用 cats.sequence.Travers...

使用匿名函数创建 FunctionK 实例

我想创建一个带有匿名函数的FunctionK实例。这是一个最小的例子： 进口猫.~> 给定（选项〜>列表）= { case Some(a) => a :: Nil 案例无 =&g...

在 Cats 和 Scala 中使用应用函子函数

如何在 Scala 3 和 Cats 中实现类似的 Haskell 函数？ ghci> (+) <$> (+1) <*> (+1) $ 10 22 有一个使用mapN的解决方案。这里提到，使用函数作为

如何一次仅在一个线程中同步一堆效果

我有一个小问题。 为了 地图 <- kafkaEventHoldLine.get // Ref[F, List[String]] key = dr.derived + dr.metricId.toString _ <- if !map.contains(key) then ...

Scala 猫异常处理

为什么它不捕获并打印来自calculateTwo的异常消息？如果我们让calculateOne抛出异常，异常就会被捕获并打印消息。 com.oxo.test 包 进口猫.d...

Scala EitherT Future 异常处理

在下面的方法中，只有来自 burnService.execute 的异常被捕获在 catch 中。来自 EarnService.execute 的任何异常都不会被捕获。如果我移动 EarnServ...

Scala、Slick、Cats - 如何使用 OptionT 映射不同的 SQL 错误？

我有一个在数据库上运行的简单灵活查询： def method(): Future[Either[Error, MyCustomDTO]] = OptionT(数据库.运行(查询)) .map(MyCustomDTO(_)) .toRight(dataNotFound()) 。价值 该...

如何在不调用内部不安全方法的情况下将结果与折叠合并

假设我有以下案例类： 案例类记录（a：字符串，b：字符串） 案例类结果（c：Int，d：Int） 以及一个执行一系列操作然后返回 IO[Result...

如何在 scala cats 中使用标志进行间隔操作

如果标志设置为 true，我需要按时间间隔运行 IO 操作。可以在一个时间间隔内从程序的其他位置多次将标志设置为 true。例如： 类IntervalAction { 绝对触摸...