scala – 用一个枚举器喂两个iteratee

发布时间：2020-12-16 18:38:04 所属栏目：安全来源：网络整理

导读：我很擅长使用框架,函数式编程和Iteratee I / O,所以也许我的问题非常缺乏主题甚至是愚蠢的. 我想将大文本文件作为流上传到第三方,同时提取有关此文件的元数据(基于其内容,简化说它是一个csv文件). 我已经编写了两个工作体解析器：Iteratee [Array [Byte],B]

我很擅长使用框架,函数式编程和Iteratee I / O,所以也许我的问题非常缺乏主题甚至是愚蠢的.

我想将大文本文件作为流上传到第三方,同时提取有关此文件的元数据(基于其内容,简化说它是一个csv文件).

我已经编写了两个工作体解析器：Iteratee [Array [Byte],B]包含写入逻辑和包含MetaData提取逻辑的Iteratee [Array [Byte],MetaData].你能告诉我如何将这两个解析器结合起来处理同时写入和提取内容

解决方法

如果你有两个迭代,it1和it1,比如说,你可以从它们创建一个“压缩”迭代器(下面的代码中的zippedIt),它会将它接收的任何输入发送到迭代器it1和it2.见 Play Iteratee documentation of zip.

这是一个例子：

import play.api.libs.iteratee.{Enumerator,Iteratee,Enumeratee}

val e = Enumerator("1","2","3")
val it1 = Iteratee.foreach[String](v => println("1: " + v))
val it2 = Iteratee.foreach[String](v => println("2: " + v))
val zippedIt = Enumeratee.zip(it1,it2)
e(zippedIt)

这个小片段的控制台输出是：

1: 1
2: 1
1: 2
2: 2
1: 3
2: 3

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!