コンジットストリームのすべての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

アレック、チャド・ギルバートとマイケルSnoymanのおかげで、私は次の解決策に来ている：このソリューションは、重複待ち受けを取り除くためにdrop機能を使用しています

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() 

。他の値を待つ前に、それを受け取るとすぐに最初の値を返します。

Answer 2

replicateM_を使用すると、重複しているawait行を取り除くことができます。

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