iteratee

4热度

1回答

在Play Scala框架中将Enumerator转换为Future[List]的标准方法是什么？

3热度

1回答

在剧中WS库，我用这电话来处理数据流的HTTP响应： def get[A](consumer: ResponseHeaders => Iteratee[Array[Byte], A]): Future[Iteratee[Array[Byte], A]] 我通过它喜欢的东西：_ => (Iteratee.foreach(chunk => println(chunk))) 一切工作正常，

2热度

2回答

通过传入n + 1个参数来定义n个参数的函数？

在什么情况下可以在功能f :: a -> b -> c -> d通过 f w x y z = ... 定义，我也不会想到这是可能的，但寻找到enumerator包时，我发现： enumFileRange :: FilePath -> Maybe Integer --^Offset -> Maybe Integer --^Maximum count

5热度

3回答

Scalaz 7处理大型压缩文件的Iteratee（OutOfMemoryError）

我正在尝试使用scalaz iteratee软件包处理恒定空间中的大型压缩文件。我需要对zip文件中的每个文件执行一个长时间运行的过程。这些进程可以（也应该）并行运行。我创建了一个EnumeratorT，它将每个ZipEntry都膨胀为File对象。签名是这样的： def enumZipFile(f:File):EnumeratorT[IoExceptionOr[IO[File]], IO]

0热度

1回答

播放框架WebSocket异步

我正在使用我的Play Framework控制器公开的WebSocket端点。然而，我的客户端会发送一个大的字节数组，我对如何在我的Iteratee中处理这个问题感到困惑。以下是我有： DEF myWSEndPoint（F：字符串=>字符串）= WebSocket.async [阵列[字节]] { 请求=> Akka.future { val (out, chan) = Concurre

0热度

1回答

异步的WebSocket在游戏框架

我从下面的帖子得到了下面的例子： http://blog.tksfz.org/2012/10/12/websockets-echo-using-play-scala-and-actors-part-i/ import play.api.libs.concurrent.Akka import play.api.Play.current // needed by Akka.future def

0热度

1回答

需要帮助，访问更多级别的json/twitter搜索

我正在使用@diegolparra做一个twitter搜索和/或流的示例。 package controllers import play.api.mvc.{WebSocket, Action, Controller} import play.api.libs.functional.syntax._ import play.api.libs.json._ import play.api.

6热度

1回答

玩Iteratee节流

我正在写一个使用Scala和Play的流式Web收音机框架。我依赖于Iteratees进行实际流式传输，但是我遇到了一个问题，试图防止贪婪的客户端太快地下载数据，并为所有客户端使用流。要做到这一点，我一直在试图创建一个Enumeratee来节制Enumerator产生数据的速度。这里是我的Enumeratee是什么样子 val throttlingIteratee = Iteratee.foldM

2热度

1回答

来自标准IO的Iteratee输入

我正在使用scalaz 6.0和scala。我使用迭代从输入流中读取。这里是我简单的叫做simple.txt的文件。这是测试我iteratee将建立一个IO单子打印线 def printLines: IterV[String, IO[Unit]] = { def step(currentIO: IO[Unit])(input: Input[String]): IterV[Str

10热度

1回答

Scala有什么开发良好的迭代器/管道库可用？

斯卡拉在Haskell的管道精神中有没有发展良好的库，或者至少有iteratee？我首先发现了Play的iteratee库，但我无法使其工作，并且它似乎与Play的并发原语Promise紧密结合，这在很多情况下可能不合适。我们也找不到任何文档，即使scaladoc非常稀疏，所以我们可以看到，Scalaz有一些迭代支持（如IterV），但似乎只有核心类没有额外的支持功能，预定义的迭代/枚举等。这很