管道獲取Network.Socket.ByteString.recv：失敗（未知錯誤）

Question

也許是一個愚蠢的做事方式，但在這裏。我想分割處理響應的HTTP請求發送/接收。

import Pipes 
import qualified Pipes.HTTP as HTTP 
import Pipes.Core 
import qualified Pipes.ByteString as PB 
import Network.Socket (withSocketsDo) 

fetch m url = do 
    req <- lift $ HTTP.parseUrl url 
    resp <- lift $ HTTP.withHTTP req m return 
    url' <- respond $ HTTP.responseBody resp 
    fetch m url' 

client :: Client String (Producer PB.ByteString IO()) IO() 
client = do 
      b <- request "http://www.google.com" 
      lift $ runEffect $ b >-> PB.stdout 

main = withSocketsDo $ HTTP.withManager HTTP.tlsManagerSettings $ \m -> 
    runEffect $ fetch m +>> client 

似乎是合法的。但我得到部分響應打印和「Network.Socket.ByteString.recv：失敗（未知錯誤）」。我需要做什麼改變？

Answer 1

的錯誤是這一部分：

HTTP.withHTTP req m return 

有個約定（不通過類型強制），當一個函數，你不能讓它分配逃脫的資源的話with開始它包含的塊。這是因爲這些函數在塊完成時處理資源，所以資源在該點之後無效。

所以發生了什麼是你試圖returnwithHTTP塊的響應，但是通過下一行代碼，響應已經被處理掉了。解決方案是使用pipes-safe，它允許您使用Pipes.Safe.bracket在管道內安全地獲取資源。所有你需要做的是提供一個開放和關閉動作：

fetch m url = do 
    req <- lift $ HTTP.parseUrl url 
    url' <- bracket openSomething closeSomething $ \resp -> do 
     respond $ HTTP.responseBody resp 
    fetch m url' 

這將確保resp不會被釋放，直到respond完成之後。