Cats是一个为Scala中的函数式编程提供抽象的库。
我正在使用Monix Task进行异步控制。如果X次以上发生故障,将并行执行场景任务,请停止所有尚未处于完整状态的任务(尽快)。解决方案I ...
Scala:找不到ContextShift [cats.effect.IO]]的隐式值>
我刚开始使用scala,想与我的数据库建立连接。 (我的知识来自https://www.scala-exercises.org/上的scala / doobie教程。)现在是代码:import doobie._ ...
Either.right =右,Either.Left =左?
在下一个站点:https://typelevel.org/cats/datatypes/two.html上显示:object EitherStyle {def parse(s:String):Either [Exception,Int] = if(s.matches( “-?[0-9] +”))要么right(...
我有一个类似这样的函数:def getFile(url:String):EitherT [Future,Error,ByteString]这正在使用猫EitherT。我使用另一个这样的函数来调用此函数:def getAllFiles(urls:...
我遇到了我的理解问题,如下所示:def doSomething():F [String] = {for {_ doSomeWork(item))// Future [] _
我想知道是否有一个函数(在scala或cat中),它忽略了flatMap中的结果。例如。 Some(“ ignore this”)。ignoreArgumentFlatMap(Some(“ result”))与Some(“ ...
这里是代码://最终将是一个具有扩展方法类的隐式类EitherTWrapper [L,R](ei:EitherT [Future,L,R])new EitherTWrapper(???:EitherT [Future,Nothing,Boolean ])失败...
[我为Map [Int,Array [Int]]定义了一个Monoid实例,并尝试使用它来合并这样的地图列表:import cats.Monoid import cats.implicits._ hidden val m:Monoid [Map [Int, Array [Int]]] = ...
我正在尝试实现一个控制摄像机的应用程序。相机命令表示为CameraAction对象的流:密封特征CameraMessage案例对象Record(recordId:String)...
MVar tryPut返回true,isEmpty也返回true
[我编写了简单的callback(handler)函数,该函数传递给异步api,我想等待结果:对象处理程序{val logger:Logger = Logger(“ Handlers”)隐式val cs:ContextShift [IO] = ...
我想按各自的顺序添加scala元组,它应按其顺序添加到列表中val d =(List.empty [String],List.empty [String],List.empty [String])(“ 1”, “ 2”,“ 3”):: d(“ 4”,“ 5”,“ 6”):: dd ...
MVar tryPut-true和isEmpty也为true
[我编写了简单的callback(handler)函数,该函数传递给异步api,我想等待结果:对象处理程序{val logger:Logger = Logger(“ Handlers”)隐式val cs:ContextShift [IO] = ...
[我有一个有效的代码:最终案例类Services [F [_]](c:Client [F],fooUrl:String)(隐式cf:ConcurrentEffect [F]){private val dsl = Http4sDsl [F] import。 ..
如何在scala中将List [Task [List [Header]]]类型转换为Task [List [Header]]。我有一个返回Task [List [Header]]并多次调用dor的方法,它成为List [Task [List [Header]]]
我具有以下数据结构:类MyDaSt [A] {def map [B:ClassTag](f:A => B)= // ...}我想实现一个Functor实例,以便能够使用临时多态性。 ...
我正在尝试使用Cats数据类型Ior来累积错误和使用服务的成功(可能会返回错误)。 def find(key:String):F [Ior [NonEmptyList [Error],A]] = {(for {...
我想使用fs2 Streams,cats EitherT和cats-effect IO定义具有以下签名的函数。 def list2Stream [A,B,F [_],S](vs:List [A],f:A => ...
我是猫和函数式编程的新手,我正努力进行单元测试像EitherT这样的函数数据类型。有示例代码:类Library [F [_]](){def create(book:Book)(隐式M:...
我已经开始使用Cats学习函数式编程,并且坚持使用flatMapping(合并)应用程序F [List]。在纯Scala中,非常简单的是将列表列表进行如下映射:val ...