2015-04-01 54 views
1

我试着这样做是为了实现一个“延迟”列表流的好方法,但没有奏效:什么是Scalaz

Process("Hello", "Salut", "Bye", "Ciao").interleave(time.sleep(0.5.seconds).repeat) 
+0

@ user2864740这意味着当向'Process'添加'Sink'(在我的情况下是标准输出)时,没有任何信息被发送到它,我试图让那些熟悉scalaz-stream的人保持简洁的问题,你是否建议我更新这个问题以提供更多的细节? – jedesah 2015-04-01 05:46:57

+0

是的 - 至少对观察到的行为有一个解释 – user2864740 2015-04-01 06:09:04

回答

1

(工艺(“你好”,“萨吕”,“再见” ,“Ciao”​​)zip(time.awakeEvery(0.5 s)) .map(_._ 1)

+0

很酷!是的,这似乎工作。任何想法为什么上述不? – jedesah 2015-04-01 22:33:44

+0

其实我认为这不起作用的原因是你交错的流,而在我的解决方案,你压缩流。我认为当你看到ZIP和INTERLEAVE的定义时就会很明显。 – 2015-04-03 05:16:02