--
You received this message because you are subscribed to the Google Groups "Haskell Pipes" group.
To unsubscribe from this group and stop receiving emails from it, send an email to haskell-pipe...@googlegroups.com.
To post to this group, send email to haskel...@googlegroups.com.
Thanks, Gabriel!
You are right, I don't need any concurrency, I just wanted to use it for the ability to broadcast producers.
I actually was looking at Fold, but I couldn't figure out how it could work for the following requirements :
- I need to group elements differently in each branch. I wouldn't be able to use pipes-groups here because it gives me functions of Producers, not Pipes.
- due to grouping my branches would emit at different rates and not for every input element. I could always emit Maybe, but it doesn't feel like a right way, does it?
In fact what I wanted is to have a stream, gather some stats on it (here is my StateT), group it in two different ways and output both results into different files.
I will have a look at Fold again, would it still be right tool for the job with the requirements I mentioned?
Cheers,
Alexey.