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