생산자와 파이프를 연결하여 결과 추출

Question

생산자가 Producer ByteString IO()이고 파이프가 Pipe ByteString a IO() 인 경우 효과를 어떻게 작성합니까? 실행하면 IO a가됩니까?

여기에 최선을 시도입니다 :

그것은 다음과 같은 실패

{-# LANGUAGE ScopedTypeVariables #-} 
import Pipes 
import Data.ByteString 

run :: forall a. IO a 
run = runEffect $ 
    (undefined :: Producer ByteString IO()) >-> (undefined :: Pipe ByteString a IO()) 

: 일반적으로

Couldn't match type `Void' with `()' 
Expected type: IO a 
    Actual type: IO() 
In the expression: 
    runEffect 
    $ (undefined :: Producer ByteString IO()) 
    >-> (undefined :: Pipe ByteString a IO()) 
In an equation for `run': 
    run 
     = runEffect 
     $ (undefined :: Producer ByteString IO()) 
      >-> (undefined :: Pipe ByteString a IO()) 

Answer 1

, 당신은 실행할 수있는 Effect을 얻을 위해 Consumer와 Producer를 구성 할 필요가 에 의해 runEffect. 여기에있는 내용이 아니지만 다행히 runEffect이 아닌 Proxy을 제거하는 방법이 더 있습니다.

우리가 가지고있는 것의 주식을 가지고이 구성은 Producer으로 끝납니다.

pipe :: Producer a IO() 
pipe = (undefined :: Producer ByteString IO()) >-> (undefined :: Pipe ByteString a IO()) 

Pipes.Prelude 모듈을 제거하기 위해 다양한 방법을 포함 Producers 아마

last :: Monad m => Producer a m() -> m (Maybe a) 

가장 일반적인 a의를 얻을 수있는 방법처럼 Pipes.Prelude.fold

fold :: Monad m => (x -> a -> x) -> x -> (x -> b) -> Producer a m() -> m b 

을 사용하는 것입니다 Pipes.Prelude.last 같은 runEffect 제외하면 Producers은 ~ Monad. 그것이 우리가 가진 것이기 때문에 위대한 일을 할 것입니다. 여기 slowHead 전체 Producer를 소비 (그리고 필요한 모든 효과 수행) 동안 Pipes.Prelude.head 수행 바로 첫 번째가된다는 사실을 주목할 필요가 있지만 우리가 Pipes.Prelude.head

slowHead = fold (\res a -> res <> First (Just a)) mempty getFirst 

을 구현할 수있는 방법입니다. 훨씬 게으르다!