組合兩個接收器的首選方法是什麼？

Question

我已經使用zipSinks :: Monad m => Sink i m r -> Sink i m r' -> Sink i m (r, r')這個，但它被認爲不推薦。

Answer 1

（（包是conduit-0.5.2.3，整個module只是爲了向下兼容。））

---

[編輯]

所以，我簡單的一元猜想（見下文）似乎是錯誤，即使類型是正確的。 現在，我只能猜測答案是：

替換功能仍在開發中，幾乎和所有Pipe/Conduit以及類似的概念和庫一樣。

我等待下一個API來解決這個問題，直到那時仍然使用zipSink。 （也許這只是放錯了地方。）

[/編輯]

我不是這個包familar，但不會是做一樣的，因爲這？

zipSinks :: Monad m => Sink i m r -> Sink i m r' -> Sink i m (r, r') 
zipSinks s1 s2 = (,) <$> s1 <*> s2 

畢竟這是一個Monad。 （Functor，Applicative）

zipSinks :: Monad sink => sink r -> sink r' -> sink (r, r') 
zipSinks s1 s2 = liftM2 (,) s1 s2 

Answer 2

編輯

考慮在此之後，我不認爲這是可能的Data.Conduit的當前版本。管道不是類別，所以&&&是不可能的。我不可能想到從上游獲得結果，逐步將它們提供給兩個接收器，並在第一個接收器結束時進行短路。 （雖然我不認爲Data.Conduit.Util.zipSinks這樣短路，但它似乎是非常可取的。）除了當然，模式匹配在兩個水槽（如包中的zipSinks），但這就是我們試圖避免在這裏。

這就是說，我會愛在這裏被證明是錯誤的。

---

這不是很漂亮，但你可以用一種明顯的方式做到這一點。

首先進口：

module Main where 

import Control.Monad.Trans 
import Data.Conduit 
import qualified Data.Conduit.Binary as CB 
import qualified Data.Conduit.List as CL 
import qualified Data.Conduit.Text as CT 
import qualified Data.Conduit.Util as CU 
import Data.Maybe 
import Data.Text (unpack) 

現在對於zipSinks。基本上，您要創建一個接收器，從上游獲取輸入，並將其分別發送給每個子接收器。在這種情況下，我用CL.sourceList來做到這一點。如果await返回Nothing,maybeToList返回一個空列表，所以子接收器也在沒有輸入的情況下運行。最後，每個子宿的輸出被輸入到元組中。

zipSinks :: Monad m => Sink i m r -> Sink i m r' -> Sink i m (r, r') 
zipSinks s1 s2 = do 
    l <- fmap maybeToList await 
    o1 <- lift $ CL.sourceList l $$ s1 
    o2 <- lift $ CL.sourceList l $$ s2 
    return (o1, o2) 

以下是使用zipSinks的一些示例。它似乎在IO內部以及其外部均正常工作，並且在我進行的少數測試中，輸出與使用舊的zipSinks創建的zipped'的輸出相匹配。

doubleHead :: Monad m => Sink Int m (Maybe Int) 
doubleHead = await >>= return . fmap (2*) 

-- old version 
zipped' :: Monad m => Sink Int m (Maybe Int, Maybe Int) 
zipped' = CU.zipSinks CL.head doubleHead 

-- new version 
zipped :: Monad m => Sink Int m (Maybe Int, Maybe Int) 
zipped = zipSinks CL.head doubleHead 

fromList = CL.sourceList [7, 8, 9] $$ zipped 
-- (Just 7, Just 14) 

fromFile :: String -> IO (Maybe Int, Maybe Int) 
fromFile filename = runResourceT $ 
     CB.sourceFile filename 
    $= CB.lines 
    $= CT.decode CT.utf8 
    $= CL.map (read . unpack) 
    $$ zipped 

-- for a file with the lines: 
-- 
-- 1 
-- 2 
-- 3 
-- 
-- returns (Just 1, Just 2)