Streamly.Internal.Data.Stream.Zip.Concurrent

To run examples in this module:

>>> import qualified Streamly.Internal.Data.Stream as Stream
>>> import qualified Streamly.Data.Fold as Fold

Documentation

newtype ZipConcurrent m a

Constructors

ZipConcurrent

Fields

• getZipConcurrent :: Stream m a

Instances

MonadAsync m => Applicative (ZipConcurrent m)

An IO stream whose applicative instance zips streams concurrently. Note that it uses the default concurrency options.

>>> s = ZipConcurrent $ Stream.fromList [1, 2, 3]
>>> x = (,,) <$> s <*> s <*> s
>>> Stream.fold Fold.toList (getZipConcurrent x)
[(1,1,1),(2,2,2),(3,3,3)]

Since: 0.9.0

Defined in Streamly.Internal.Data.Stream.Zip.Concurrent

Methods

pure :: a -> ZipConcurrent m a

(<*>) :: ZipConcurrent m (a -> b) -> ZipConcurrent m a -> ZipConcurrent m b

liftA2 :: (a -> b -> c) -> ZipConcurrent m a -> ZipConcurrent m b -> ZipConcurrent m c

(*>) :: ZipConcurrent m a -> ZipConcurrent m b -> ZipConcurrent m b

(<*) :: ZipConcurrent m a -> ZipConcurrent m b -> ZipConcurrent m a

Monad m => Functor (ZipConcurrent m)

Defined in Streamly.Internal.Data.Stream.Zip.Concurrent

Methods

fmap :: (a -> b) -> ZipConcurrent m a -> ZipConcurrent m b

(<$) :: a -> ZipConcurrent m b -> ZipConcurrent m a