@@ -22,6 +22,7 @@ module Asyncly.AsyncT
22 , MonadAsync
22 , MonadAsync
23 , runAsyncly
23 , runAsyncly
@@ -691,6 +692,17 @@ toList m = (runAsyncT m) Nothing stop yield
691 yield a Nothing = return [a]
692 yield a Nothing = return [a]
692 yield a (Just x) = liftM (a :) (toList x)
693 yield a (Just x) = liftM (a :) (toList x)
695+next :: MonadAsync m => AsyncT m a -> m (Maybe (a, AsyncT m a))
696+next m = (runAsyncT m) Nothing stop yield
700+ stop = return Nothing
702+ {-# INLINE yield #-}
703+ yield a Nothing = return (Just (a, empty))
704+ yield a (Just x) = return (Just (a, x))
694------------------------------------------------------------------------------
706------------------------------------------------------------------------------
695-- Transformation
707-- Transformation
696------------------------------------------------------------------------------
708------------------------------------------------------------------------------
@@ -742,7 +754,9 @@ zipWith f m1 m2 = AsyncT $ \_ stp yld -> do
742 yield1 a (Just ra) = merge a ra
754 yield1 a (Just ra) = merge a ra
743 (runAsyncT m1) Nothing stp yield1
755 (runAsyncT m1) Nothing stp yield1
745−-- | Wrapper around AsyncT type with a serial zipping Applicative instance
757+-- | Wrapper around AsyncT type with a serial zipping Applicative instance.
758+-- Note that the binary function interleave (<=>) is a special case of
759+-- ZipSerial Applicative.
747-- > f <$> ZipSerial xs1 <*> ... <*> ZipSerial xsN
761-- > f <$> ZipSerial xs1 <*> ... <*> ZipSerial xsN
748newtype ZipSerial m a = ZipSerial {getZipSerial :: AsyncT m a}
762newtype ZipSerial m a = ZipSerial {getZipSerial :: AsyncT m a}
@@ -797,7 +811,9 @@ zipAsyncWith f m1 m2 = AsyncT $ \_ stp yld -> do
797 mb <- async m2
811 mb <- async m2
798 (runAsyncT (zipWith f ma mb)) Nothing stp yld
812 (runAsyncT (zipWith f ma mb)) Nothing stp yld
800−-- | Wrapper around AsyncT type with a parallel zipping Applicative instance
814+-- | Wrapper around AsyncT type with a parallel zipping Applicative instance.
815+-- Note that the binary operator (<|>) from the Alternative instance of AsyncT
816+-- is a special case of ZipAsync Applicative.
802-- > f <$> ZipAsync xs1 <*> ... <*> ZipAsync xsN
818-- > f <$> ZipAsync xs1 <*> ... <*> ZipAsync xsN
803newtype ZipAsync m a = ZipAsync {getZipAsync :: AsyncT m a}
819newtype ZipAsync m a = ZipAsync {getZipAsync :: AsyncT m a}