Fusion.MStream -> Fusion.Stream.Monadic