Cách ưa thích để kết hợp hai bồn rửa là gì?

Question

Tôi đã sử dụng zipSinks :: Monad m => Sink i m r -> Sink i m r' -> Sink i m (r, r') cho điều này nhưng bị coi là không dùng nữa.

Answer 1

((Các gói phần mềm là conduit-0.5.2.3. Toàn bộ module chỉ là để tương thích ngược.))

---

[chỉnh sửa]

Vì vậy, đoán monadic đơn giản của tôi (xem dưới đây) dường như là sai, mặc dù các loại là chính xác. Bây giờ, tôi chỉ có thể đoán rằng câu trả lời là:

Các tính năng thay thế vẫn đang được phát triển, khá nhiều giống như tất cả ống/Conduit và các khái niệm và các thư viện tương tự.

Tôi sẽ đợi API tiếp theo giải quyết câu hỏi này và vẫn sử dụng zipSink cho đến lúc đó. (Có lẽ nó đã được chỉ đặt không đúng chỗ.)

[/chỉnh sửa]

tôi không phải là quen với gói này, nhưng nó sẽ không làm chỉ giống như này?

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

Sau cùng, tất cả là Monad. (Functor, Applicative)

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

Answer 2

Sửa

Sau khi xem xét này, tôi không nghĩ rằng nó có thể với phiên bản hiện tại của Data.Conduit. Ống không phải là Danh mục, do đó, &&& không nằm trong câu hỏi. Và không có cách nào mà tôi có thể nghĩ đến để kéo kết quả từ thượng nguồn, cho chúng tăng dần lên cả hai bồn rửa và ngắn mạch khi bồn rửa đầu tiên kết thúc. (Mặc dù tôi không nghĩ rằng ngắn mạch theo cách này, nó có vẻ như nó sẽ rất hấp dẫn.) Ngoại trừ tất nhiên, để phù hợp với mô hình trên cả hai Sinks (như zipSinks trong gói), nhưng đó là những gì chúng tôi cố gắng tránh ở đây.

Điều đó nói rằng, tôi sẽ yêu thích để được chứng minh là sai ở đây.

---

Nó không đẹp, nhưng bạn có thể làm điều này một cách rõ ràng.

nhập khẩu đầu tiên:

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) 

Bây giờ cho zipSinks. Về cơ bản, bạn muốn tạo một bồn rửa kéo đầu vào từ phía trên và gửi nó đến từng bồn rửa riêng biệt. Trong trường hợp này, tôi đã sử dụng CL.sourceList để thực hiện việc này. Nếu await trả về Nothing, maybeToList trả về một danh sách trống, vì vậy các bồn rửa trẻ em cũng được chạy mà không có đầu vào. Cuối cùng, đầu ra của mỗi bồn rửa trẻ em sau đó được đưa vào tuple.

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) 

Dưới đây là một số ví dụ về cách sử dụng zipSinks. Nó xuất hiện để làm việc tốt cả bên trong của IO và bên ngoài của nó, và trong vài bài kiểm tra tôi đã làm, đầu ra phù hợp với đầu ra của zipped', tạo ra bằng cách sử dụng cũ zipSinks.

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)