b52ed84 · streamly · git.iko.soy

git.iko.soy/streamly

on master help sign in

Make classifySessionsOf terminate

b52ed84Harendra Kumar6 years ago

src/Streamly/Internal/Prelude.hs+10−1

@@ -4687,7 +4687,7 @@ classifySessionsBy tick tmout reset ejectPred

4687 return (hp, mp, out, cnt)

4688

4689 -- merge timer events in the stream

4690− stream = Serial.map Just str `Par.parallel` repeatM timer

4690+ stream = Serial.map Just str `Par.parallelFst` repeatM timer

4691 timer = do

4692 liftIO $ threadDelay (round $ tick * 1000000)

4693 return Nothing

@@ -4761,6 +4761,15 @@ classifyChunksOf wsize = classifyChunksBy wsize False

4761-- classifySessionsOf interval pred = classifySessionsBy 1 interval False pred

4762-- @

4763--

4764+-- @

4765+-- >>> S.mapM_ print

4766+-- $ S.classifySessionsOf 3 (const (return False)) (fmap Right FL.toList)

4767+-- $ S.map (\(ts,(k,a)) -> (k, a, ts))

4768+-- $ S.timestamped

4769+-- $ S.delay 1

4770+-- $ (,) <$> S.fromList [1,2,3] <*> S.fromList [1,2,3]

4771+-- @

4772+--

4764-- /Internal/

4773-- /Internal/

4765--

4774--

4766{-# INLINABLE classifySessionsOf #-}

4775{-# INLINABLE classifySessionsOf #-}