我试着这样做是为了实现一个“延迟”列表流的好方法,但没有奏效:什么是Scalaz
Process("Hello", "Salut", "Bye", "Ciao").interleave(time.sleep(0.5.seconds).repeat)
我试着这样做是为了实现一个“延迟”列表流的好方法,但没有奏效:什么是Scalaz
Process("Hello", "Salut", "Bye", "Ciao").interleave(time.sleep(0.5.seconds).repeat)
(工艺(“你好”,“萨吕”,“再见” ,“Ciao”)zip(time.awakeEvery(0.5 s)) .map(_._ 1)
很酷!是的,这似乎工作。任何想法为什么上述不? – jedesah 2015-04-01 22:33:44
其实我认为这不起作用的原因是你交错的流,而在我的解决方案,你压缩流。我认为当你看到ZIP和INTERLEAVE的定义时就会很明显。 – 2015-04-03 05:16:02
@ user2864740这意味着当向'Process'添加'Sink'(在我的情况下是标准输出)时,没有任何信息被发送到它,我试图让那些熟悉scalaz-stream的人保持简洁的问题,你是否建议我更新这个问题以提供更多的细节? – jedesah 2015-04-01 05:46:57
是的 - 至少对观察到的行为有一个解释 – user2864740 2015-04-01 06:09:04