如何在管道中使用导管下降功能？

我有一个简单的任务 - 从文件中读取一堆行并对每一行执行一些操作。除了第一个 - 这是一些需要忽略的标题。

所以我想我应该尝试一下管道。

printFile src = runResourceT $ CB.sourceFile src =$= 
    CT.decode CT.utf8 =$= CT.lines =$= CL.mapM_ putStrLn

Cool.

所以现在我只想删除第一行......似乎有一个函数可以做到这一点 -

printFile src = runResourceT $ CB.sourceFile src =$= 
    CT.decode CT.utf8 =$= CT.lines =$= drop 1 =$= CL.mapM_ putStrLn

嗯 - 但现在我注意到 drop 有类型签名Sink a m ()。有人向我建议我可以使用 Monad 实例作为管道，并使用 drop 来有效地删除一些元素 - 所以我尝试了这个：

drop' :: Int -> Pipe a a m ()
drop' n = do
  CL.drop n
  x <- await
  case x of 
    Just v -> yield v
    Nothing -> return ()

它不会进行类型检查，因为管道的 monad 实例仅适用于相同类型的管道 - 接收器将 Void 作为其输出，所以我不能像这样使用它。

我快速浏览了 Pipes 和 Pipes-Core，发现 Pipes-Core 具有我预期的功能，其中 Pipes 是一个最小的库，但文档显示了它的实现方式。

所以我很困惑 - 也许我缺少一个关键概念..我看到了这个功能

sequence ::  Sink input m output -> Conduit input m output

但这似乎不是正确的想法，因为输出值为 ()

CL.sequence (CL.drop 1) :: Conduit a m ()    

我可能会回去使用lazy-io，因为我真的不需要任何流媒体 - 但我有兴趣了解正确的方法。

首先，简单回答一下：

... =$= CT.lines =$= (CL.drop 1 >> CL.mapM_ putStrLn)

更长的解释：实际上有两种不同的方法可以实现drop。不管怎样，它都会先掉落n来自输入的元素。关于它接下来要做什么有两种选择：

• 说已经完成了
• 开始输出输入流中的所有剩余项目

前一种行为是Sink将执行（以及我们的drop实际上是这样），而后者是Conduit。事实上，您可以通过单子组合从前者生成后者：

dropConduit n = CL.drop n >> CL.map id

然后你可以使用dropConduit正如你在开头所描述的。这是展示单子组合和融合之间差异的好方法；前者允许两个函数在同一输入流上运行，而后者允许一个函数将流提供给另一个函数。

我还没有进行基准测试，但我相当确定单子组合会更有效一些。