* `Process1[I,O] Tee[I,I2,O]`.
*/
type Tee[-I,-I2,+O] = Process[Env[I,I2]#T, O]
我们看到tee的类型款式很像...O](rcv: I2 => Tee[I, I2, O]): Tee[I, I2, O] =
await[Env[I, I2]#T, I2, O](R)(rcv)
与await1同样,receiveL...(padI, padI2)((_, _))
我们用以下例子来示范这些函数的使用方法:
1 import tee._
2 val source = range(1,6).toSource...我们的目的是把一串现成的元素插入形成的流,无论从左或右都无所谓)
1 val ltee = tee.feedL(Seq(1,2,3))(id[Int]) //> ltee : scalaz.stream.Tee...[Int,Any,Int] = Append(Emit(Vector(1, 2)),Vector(1>))
2 halt.tee[Task,Int,Int](halt)(ltee).