Diamondy Franc

Issue example: ```haskell import qualified Streamly.Prelude as Stream import qualified Streamly.Internal.Data.Stream.IsStream as StreamEx main :: IO () main = Stream.repeat 5 & Stream.delay 1000 & Stream.chunksOfTimeout 10 1 Fold.length &...

Maybe this is XY problem and what I'm trying to do is wrong. Basically I want to stop streaming new elements but keep already read data in processing. I have...

Thanks! I'll try this. Actually I just need to be able to stop (possibly infinite) stream on condition like takeWhileM does, but on-demand, not as check after each new element...

I have multiple consumers running every X seconds (at different time), who should flush whole chan contents into some IO action, so I think - yes - I want to...

I think it could be connected to [9.4 changes](https://downloads.haskell.org/~ghc/9.4.2/docs/users_guide/9.4.1-notes.html#breaking-changes), namely: ``` There were previously cases around functional dependencies and injective type families where the result of type inference would depend...

> I've minimized the example and reported upstream as [GHC#22516](https://gitlab.haskell.org/ghc/ghc/-/issues/22516). Was very busy and forgot about reporting this bug to GHC. Thanks!