c49732a · streamly · git.iko.soy

git.iko.soy/streamly

on master help sign in

Move the each primitive to right place

c49732aHarendra Kumar9 years ago

src/Asyncly/AsyncT.hs+6−6

@@ -145,12 +145,6 @@ instance (Monoid a, MonadAsync m) => Monoid (AsyncT m a) where

145 mappend x y = mappend <$> x <*> y

146 mempty = return mempty

147

148−-- scatter

149−{-# SPECIALIZE each :: [a] -> AsyncT IO a #-}

150−each :: (MonadIO m, MonadBaseControl IO m, MonadThrow m)

151− => [a] -> AsyncT m a

152−each xs = foldr (<|>) empty $ map return xs

153−

154------------------------------------------------------------------------------

148------------------------------------------------------------------------------

155-- Num

149-- Num

156------------------------------------------------------------------------------

150------------------------------------------------------------------------------

@@ -283,6 +277,12 @@ async action = AsyncT $ runAsyncTask True (runAsyncT action)

283makeAsync :: MonadAsync m => ((a -> m ()) -> m ()) -> AsyncT m a

277makeAsync :: MonadAsync m => ((a -> m ()) -> m ()) -> AsyncT m a

284makeAsync = AsyncT . makeCont

278makeAsync = AsyncT . makeCont

285

279

280+-- scatter

281+{-# SPECIALIZE each :: [a] -> AsyncT IO a #-}

282+each :: (MonadIO m, MonadBaseControl IO m, MonadThrow m)

283+ => [a] -> AsyncT m a

284+each xs = foldr (<|>) empty $ map return xs

285+

286------------------------------------------------------------------------------

287-- Controlling thread quota

288------------------------------------------------------------------------------