我試着這樣做是爲了實現一個「延遲」列表流的好方法,但沒有奏效:什麼是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