도관 스트림의 모든 n 번째 요소를 유지하십시오.

Question

도관을 사용하여 일부 데이터를 스트림 방식으로 구문 분석하고 있습니다. 스트림의 어느 시점에서 나는 매 12 번째 요소가 필요합니다. 이 작업을 수행하는 편리한 방법이 있습니까?

나는 현재 명시 적으로 단지 첫 번째 요소 반환 (12 개) 요소를 기다리고 있어요 :

get12th :: Monad m => Conduit Int m Int 
get12th = loop 
    where 
    loop = do 
     v1 <- await 
     _ <- await 
     _ <- await 
     _ <- await 
     _ <- await 
     _ <- await 
     _ <- await 
     _ <- await 
     _ <- await 
     _ <- await 
     _ <- await 
     _ <- await 
     case v1 of 
      Nothing -> return() 
      Just x -> do 
       yield x >> loop 

그것은 작동하지 않습니다,하지만이 그것을 할 수있는 가장 좋은 방법이 있는지 궁금 하군요.

Answer 1

덕분에, 나는 다음과 같은 솔루션에 왔어요 :

는

get12th :: Monad m => Conduit Int m Int 
get12th = loop 
    where loop = do 
      v <- await 
      case v of 
      Just x -> yield x >> CL.drop 11 >> loop 
      Nothing -> return() 

이 솔루션은 중복 기다리고 제거 할 수있는 drop 함수를 사용합니다. 다른 값을 기다리기 전에 먼저 값을 받으면 즉시 값을 반환합니다.

Answer 2

await 행을 제거하려면 replicateM_을 사용할 수 있습니다. 알렉, 차드 길버트와 마이클 Snoyman에

v1 <- await 
replicateM_ 11 await 
case v1 of 
    ...