scala – 如何创建循环流？

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

导读：我正在尝试使用 scalaz-stream创建一个循环过程,方法是将一个数据源与来自同一数据源的过滤版本合并.这是我到目前为止的一个简单例子： val s1 = Process.emitAll(1 to 10).toSourceval w = wye.merge[Int]val s2 = w.filter(_ 5)val w2 = s1.wye(s2)(w) 但

我正在尝试使用 scalaz-stream创建一个循环过程,方法是将一个数据源与来自同一数据源的过滤版本合并.这是我到目前为止的一个简单例子：

val s1 = Process.emitAll(1 to 10).toSource

val w = wye.merge[Int]

val s2 = w.filter(_ < 5)

val w2 = s1.wye(s2)(w)

但它不编译,因为s2是Process [Process.Env [Int,Int] #Y,Int],但需要是Process [Task,Int].

如何指定s2既是输入(带有s1)又是w的输出？

解决方法

请参阅 this answer on the scalaz-mailing list简短回答是不可能完全按照您的要求进行操作,但通常还有其他方法可以解决您的问题.

（编辑：李大同）

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