我正在尝试使用
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的输出？
