ある川AがNext X を発行した時、別の川Bの最新の値がある値YならばそのNextを通して、もしそうでないならば、BがYを送り出すまで待って、Yが来たらXを流すっていう制御をしたかったんだけど

2:22 AM

昨日結構悩んだんだけど、 A.flatMap { x in B.filter(isY).take(1).map{ _ in x } } だった。flatMapすごい。 (edited)