回答情况：
提问时间：
问题标签：
我有一个Process[Task, A]，我需要在流的每个A上运行一个函数A => B，它的运行时间范围从瞬时到很长，以产生一个Process[Task, B]。一个具体的例子是下面的代码，我希望所有的奇数都能立即打印出来，而偶数大约要在500ms后打印出来。取而代之的是打印(奇数，偶数)对，并以500ms的停顿进行交错：import scala.concurr
浏览 1修改于2015-08-11得票数 1
考虑下面的代码：import scalaz.concurrent.Task v = 0 }
val expensiveCalcul
浏览 3提问于2016-04-04得票数 0
我想通过db.stream(yourquery)通过scalaz-stream流式传输从一个巧妙的3.0.0查询返回的数据。如何在从scalaz-stream流程回流到slick publisher的反压力下做到这一点？
浏览 0修改于2015-02-26得票数 4
我试着在代码运行时使用scalaz-stream队列发送日志作为副作用，但最终结果相当丑陋：
def execute(): Process[Task, String \/ ProcessResult]
浏览 1提问于2014-08-26得票数 1
) => responsePromise map Some.apply }}
做同样的事情，等价的scalaz-stream
浏览 3修改于2017-05-23得票数 5
由于我对这两者的了解有限，我可以将scalaz-stream为资源管理提供的支持视为一个重要的区别。
其他主要区别是什么？
浏览 3提问于2015-03-03得票数 4
1回答
在下面的scalaz-stream使用示例(取自)中，如果输入和/或输出是一个压缩文件，我需要更改什么？换句话说，我如何使用？
浏览 0提问于2015-05-04得票数 3
回答已采纳
如何加快以下scalaz-stream代码的速度？目前，处理70 of的文本大约需要5分钟，所以我可能做了一些非常错误的事情，因为普通的scala等价物需要几秒钟时间。
浏览 3修改于2017-05-23得票数 3
回答已采纳
1回答
我试图使用scalaz-stream同时处理多个文件，对所有文件中的每一行应用一个函数。具体而言，假设我有一个函数，该函数接受字符串列表。
浏览 1提问于2013-11-21得票数 1
回答已采纳
test->test")
akkaDeps Seq(scalaz, `scalaz-concurrent`, `scalaz-stream
浏览 0修改于2015-05-27得票数 3
http://repo.spray.io/",
"Scalaz Bintray Repo" at "http://dl.bintray.com/scalaz/releases" // for scalaz-stream
浏览 3修改于2015-04-10得票数 1
回答已采纳
+= "org.scalaz" %% "scalaz-concurrent" % "7.1.0"
//libraryDependencies += "org.scalaz.stream" %% "scalaz-stream
浏览 2修改于2014-09-09得票数 0
1回答
junit" % "junit" % "4.12" % "test",
"org.scalaz.stream" %% "scalaz-stream
浏览 5提问于2015-06-22得票数 0
回答已采纳
我曾经获得了scalaz-stream v0.7a的依赖，但它似乎不再出现在网站上了。有一个快照-0.7a，我想用它..然而，我只需要知道如何将版本切换到这个版本？
浏览 11提问于2021-06-03得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号