composewell/streamly
1
1
Fork 0
mirror of https://github.com/composewell/streamly.git synced 2024-09-20 07:58:27 +03:00
Code Issues Packages Projects Releases Wiki Activity

Simplify runner functions

Browse Source
This commit is contained in:
Harendra Kumar 2017-08-25 23:38:54 +05:30
parent ab91267967
commit 2248afac5e
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Asyncly/RunAsync.hs
View File

@ -83,8 +83,11 @@ runAsynclyLogged lref m = run Nothing m
where
stop = return ()
{-# INLINE yield #-}
yield _ c r = maybe stop (\x -> (run c x)) r
yield _ _ Nothing = stop
yield _ c (Just x) = run c x
run ct mx = (runAsyncT mx) ct stop yield
runAsyncly :: MonadAsync m => AsynclyT m a -> m ()
@ -99,9 +102,10 @@ toList m = run Nothing m
where
stop = return []
done a = return [a]
{-# INLINE yield #-}
yield a c r = maybe (done a) (\x -> liftM (a :) (run c x)) r
yield a _ Nothing = return [a]
yield a c (Just x) = liftM (a :) (run c x)
{-# INLINE run #-}
run ctx mx = (runAsyncT mx) ctx stop yield