PureScript에서 하나의 Producer를 사용하여 여러 동시 소비자에게 어떻게 가입합니까?

Question

나는 코 루틴 생산자와 소비자를 이해하기 시작하고 있다고 생각하지만, 소비자와 생산물을 유용한 방법으로 함께 모으는 데 가장 힘든 시간을 보내고 있습니다. 나는 APIEvent의 생산을 ...있는 경우

type ID = String 

data APIEvent 
    = Connecting 
    | Fail String 
    | Success String 

derive instance gAPIEvent :: Generic APIEvent 
instance showPeerEvent :: Show APIEvent where show = gShow 

getID :: Producer APIEvent (Aff (avar :: AVAR, console :: CONSOLE, random :: RANDOM)) (Maybe ID) 
getID = produceAff (\emit -> do 
    i <- liftEff $ randomInt 0 10 
    if i < 9 
    then do 
     -- If producer was called with `loop`, the 
     -- producer will restart. 
     emit $ Left $ Fail "Failure to get id." 
     emit $ Right Nothing 
    else do 
     emit $ Left $ Success "id" 
     emit $ Right $ Just "id" 
) 

나는 시스템 로깅 및 기본 출력, 예를 들어,을 두 소비자에 연결 할 방법

logFailures :: Consumer APIEvent (Aff (avar :: AVAR, console :: CONSOLE, random :: RANDOM)) ID 
logFailures = forever $ do 
    event <- await 
    lift $ do 
    case event of 
     (Fail message) -> log $ "LOG: " <> message 

showOutput :: Consumer APIEvent (Aff (avar :: AVAR, console :: CONSOLE, random :: RANDOM)) ID 
showOutput = forever $ do 
    event <- await 
    lift $ do 
    log $ "STDOUT: " <> (show event) 

내가 joinConsumers를 사용하여 시도했지만, 그 (Tuple APIEvent APIEvent)의 소비자를 생성 대신 APIEvent의의는, 그럼 이 수표를 입력하지 않습니다.

main = launchAff $ do 
    v <- runProcess $ 
     (joinConsumers logFailures showOutput) 
     `pullFrom` (loop getPeerID) 
    log $ "Process result: " <> (show v) 

편집 :

이 내가 함께 끝난 것입니다. 당신이 발견 한 것처럼

main = launchAff $ do 
    v <- runProcess $ 
    transformConsumer 
     (forever $ transform (\i -> Tuple i i)) 
     (joinConsumers logFailures showOutput) 
    `pullFrom` (loop getID) 
    log $ "Process result: " <> (show v) 

출력

...

LOG: Failure to get id. 
STDOUT: Test.SO.Fail "Failure to get id." 
LOG: Failure to get id. 
STDOUT: Test.SO.Fail "Failure to get id." 
STDOUT: Test.SO.Success "id" 
Process result: "id" 

Answer 1

, 당신은 ConsumerTuple의의에이 개 Consumer 결합에 joinConsumers를 사용할 수 있습니다. 이제 Consumer이 Tuple a a 인 일반 Consumer을 a으로 변경하는 방법이 필요합니다.

transformConsumer 
    :: forall i o f m a 
    . (MonadRec m, Parallel f m) 
    => Transformer i o m a 
    -> Consumer o m a 
    -> Consumer i m a 

하지만 어떻게 거기 Transformer를 만들 : 당신은 Transformer가 사용 Consumer를 변환하는 transformConsumer 기능을 사용하여이 작업을 수행 할 수 있습니다

? 글쎄, 당신은 transform 함수를 사용하여 일반 함수에서 하나를 만들 수 있습니다 : 당신이 필요로하는

transform 
    :: forall m i o 
    . Monad m 
    => (i -> o) 
    -> Transformer i o m Unit 

기능 유형은 a -> Tuple a a, 그래서 \a -> Tuple a a이 일을 할 것입니다.