@@ -590,11 +590,13 @@ concatMap f m = fromStreamD $ D.concatMap (toStreamD . f) (toStreamD m)
591-- See also: 'concat', 'sequence'
591-- See also: 'concat', 'sequence'
593−-- /Internal/
593+-- /Inhibits stream fusion/
595{-# INLINE concatEffect #-}
595{-# INLINE concatEffect #-}
596concatEffect :: Monad m => m (Stream m a) -> Stream m a
596concatEffect :: Monad m => m (Stream m a) -> Stream m a
597−concatEffect generator = concatMapM (\() -> generator) (fromPure ())
597+-- concatEffect generator = concatMapM (\() -> generator) (fromPure ())
598+concatEffect generator =
599+ fromStreamK $ K.concatEffect $ fmap toStreamK generator
599-- XXX Need a more intuitive name, and need to reconcile the names
601-- XXX Need a more intuitive name, and need to reconcile the names
600-- foldMany/fold/parse/parseMany/parseManyPost etc.
602-- foldMany/fold/parse/parseMany/parseManyPost etc.