haskell - 我可以制作一个消耗所有生产者输出并将其作为列表传递的管道吗？

Question

我正在尝试使用 Pipes 库对工作流程进行建模。在那个工作流程中，我想从一个生产者那里积累所有的输出，然后把它传递下去。在这种情况下，我知道我的生产者产生了有限数量的输出。

所以如果我有:

prod :: Producer a m ()
accum :: Pipe a [a] m r
groupConsumer :: Consumer [a] m r

我如何建模 accum这样我就可以做到:

runEffect $ prod >-> accum >-> groupConsumer

谢谢!

Answer 1

您可以使用 Pipes.Prelude.toListM收集 Producer进入列表:

Pipes.Prelude.toListM :: (Monad m) => Producer a m () -> m [a]

Pipes.Prelude.toListM prod :: (Monad m) => m [a]

然后您只需将该列表提供给您的 groupConsumer :

runEffect $ (lift (Pipes.Prelude.toListM prod) >>= yield) >-> groupConsumer