conduit

2热度

1回答

我想了解如何捕获管道内引发的错误。我相信，通过在管道上应用catchC，我可以生产一个新的管道，在发生故障时重新运行。在下面的例子中，我们有一个来源，根据布尔值，将会抛出一个自定义的虚拟异常。最初是布尔导致了异常值被抛出，但是里面catchC处理程序产生应（从1到10，得到的数字）表现出相反的行为的新管道 {-# LANGUAGE DeriveDataTypeable #-} module

1热度

2回答

如何从Phabricator使用导管获得（使用PHP）的差异

您可以帮助我一个关于如何使用导管在Phabricator中获得差异的工作示例吗？我想写一个脚本来根据不同的标准（如状态，每个用户等）从Phabricator获取差异列表。我已经看到有一个与Phabricator命名管道（https://secure.phabricator.com/book/phabdev/article/conduit/）的api连接的软件包，但是虽然提供了ConduitCli

1热度

1回答

与Haskell Conduit重复使用sinkFile

我想将照片列表发送到接收器以将它们保存在磁盘上。每个照片结构包含一个类型为懒惰ByteString的content字段。基本上我想要做这样的事情： CL.sourceList photos $$ sinkPhotos 我想在我的片重用CB.sinkFile，因为，如果我理解正确的话，它的错误管理。这里是我的尝试至今： mkFilePath :: Photo -> FilePath mkFil

3热度

1回答

如何使用导管建模嵌套流？

假设我们需要总结存储在文件中的数字组，其中组由空行分隔。所以 1 2 3 4 5 应该结果在6 9。对嵌套管道进行建模似乎很自然：外部管道将线路分成线组，其中每个组本身就是源。但是，我没有看到这种风格直接支持管道。用导管做这件事最常用的方法是什么？

0热度

1回答

csv-conduit能否以csv形式读取字符串并将其解析为某种中间数据类型？

CSV-管道的GitHub的网页上找到的文档很少，我的用例涉及读取一个字符串CSV形式，即： csv :: String csv = "\"column1 (text)\",\"column2 (text)\",\"column3 (number)\",\"column4 (number)\"\r\anId,stuff,12,30.454\r\n" 并将其转换成一些中间数据类型，因此，假设我

0热度

1回答

导管流的操作列表

我有：无限网络流作为源(responseBody response) 解析器：类型的myParser = many1 parseOneObjParser [MyObj] 我想处理的每个对象（为例如在屏幕上打印它）。我被困在这里。我试过这样的东西： responseBody response C.$$++ sinkParser myParser C.$$-- CL.mapM_

1热度

1回答

Conduit简单文件读取表达式不是类型检查

我试图在我的带子下得到一个简单的conduit示例，但我在类型检查阶段失败。在this example中，我看到ResourceT被用作管道“执行者”，如果这是有道理的话。我也知道，一段时间以来，ResourceT已经是factored-out into it's own package。但是，我仍然无法得到一个简单的例子。这里是我的代码，这是由this article启发： import qua

3热度

1回答

管道流中的并行处理

我非常喜欢管道/管道的概念，用于将操作应用于流式IO源。我有兴趣构建可用于非常大的日志文件的工具。从Python/Ruby移植到Haskell的一个优点是编写并行代码更简单，但我找不到任何文档。我怎样才能建立一个从文件中读取行并对它们进行并行处理的管道流（即，使用8个内核，它应该读取8行，并将它们交给8个不同的线程进行处理，然后再次收集等等），理想情况下尽可能少的“仪式”... 可选地，可以指出是

0热度

1回答

SHA256上传的文件在Yesod中 - 使用Conduit和Data.Digest.Pure.SHA

我正在使用yesod处理文件上传，并希望将上传的文件保存到我的服务器上的一个文件中，名称为SHA256内容。我认为处理级别的功能将类似于： fileMove fInfo (basePath <> generateSha fInfo) 这个问题是围绕着如何写generateSha :: FileInfo -> String中心。我看到，很可能是一些实用的功能： fileSource :: M

0热度

1回答

为什么在使用网络管道时等待总是返回什么？

我正试图学习如何使用管道。我有一个管道，它接收字节串并将它们分组成表示要发送到服务器的操作的数据包。然后我有一个管道，它接收这些数据包，对它们进行操作并产生响应数据包。最后，我有一个管道，它接收响应数据包并将它们变成一串字节串。问题是数据包处理管道中的产量总是返回Nothing。我的代码看起来像这样 processingConduit :: ServerState -> Conduit BS.By