Streamly.Internal.Data.Stream.Zip

To run examples in this module:

>>> import qualified Streamly.Prelude as Stream

Documentation

newtype ZipSerialM m a

For ZipSerialM streams:

(<>) = serial
(*) = 'Streamly.Prelude.serial.zipWith' id

Applicative evaluates the streams being zipped serially:

>>> s1 = Stream.fromFoldable [1, 2]
>>> s2 = Stream.fromFoldable [3, 4]
>>> s3 = Stream.fromFoldable [5, 6]
>>> Stream.toList $ Stream.fromZipSerial $ (,,) <$> s1 <*> s2 <*> s3
[(1,3,5),(2,4,6)]

Since: 0.2.0 (Streamly)

Since: 0.8.0

Constructors

ZipSerialM

Fields

• getZipSerialM :: Stream m a

Instances

IsStream ZipSerialM

Defined in Streamly.Internal.Data.Stream.IsStream.Type

Methods

toStream :: forall (m :: Type -> Type) a. ZipSerialM m a -> Stream m a

fromStream :: forall (m :: Type -> Type) a. Stream m a -> ZipSerialM m a

consM :: MonadAsync m => m a -> ZipSerialM m a -> ZipSerialM m a

(|:) :: MonadAsync m => m a -> ZipSerialM m a -> ZipSerialM m a

Monad m => Functor (ZipSerialM m)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

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

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

Monad m => Applicative (ZipSerialM m)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

pure :: a -> ZipSerialM m a

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

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

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

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

(Foldable m, Monad m) => Foldable (ZipSerialM m)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

fold :: Monoid m0 => ZipSerialM m m0 -> m0

foldMap :: Monoid m0 => (a -> m0) -> ZipSerialM m a -> m0

foldMap' :: Monoid m0 => (a -> m0) -> ZipSerialM m a -> m0

foldr :: (a -> b -> b) -> b -> ZipSerialM m a -> b

foldr' :: (a -> b -> b) -> b -> ZipSerialM m a -> b

foldl :: (b -> a -> b) -> b -> ZipSerialM m a -> b

foldl' :: (b -> a -> b) -> b -> ZipSerialM m a -> b

foldr1 :: (a -> a -> a) -> ZipSerialM m a -> a

foldl1 :: (a -> a -> a) -> ZipSerialM m a -> a

toList :: ZipSerialM m a -> [a]

null :: ZipSerialM m a -> Bool

length :: ZipSerialM m a -> Int

elem :: Eq a => a -> ZipSerialM m a -> Bool

maximum :: Ord a => ZipSerialM m a -> a

minimum :: Ord a => ZipSerialM m a -> a

sum :: Num a => ZipSerialM m a -> a

product :: Num a => ZipSerialM m a -> a

Traversable (ZipSerialM Identity)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

traverse :: Applicative f => (a -> f b) -> ZipSerialM Identity a -> f (ZipSerialM Identity b)

sequenceA :: Applicative f => ZipSerialM Identity (f a) -> f (ZipSerialM Identity a)

mapM :: Monad m => (a -> m b) -> ZipSerialM Identity a -> m (ZipSerialM Identity b)

sequence :: Monad m => ZipSerialM Identity (m a) -> m (ZipSerialM Identity a)

NFData1 (ZipSerialM Identity)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

liftRnf :: (a -> ()) -> ZipSerialM Identity a -> ()

IsList (ZipSerialM Identity a)

Defined in Streamly.Internal.Data.Stream.Zip

Associated Types

type Item (ZipSerialM Identity a)

Methods

fromList :: [Item (ZipSerialM Identity a)] -> ZipSerialM Identity a

fromListN :: Int -> [Item (ZipSerialM Identity a)] -> ZipSerialM Identity a

toList :: ZipSerialM Identity a -> [Item (ZipSerialM Identity a)]

Eq a => Eq (ZipSerialM Identity a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

(==) :: ZipSerialM Identity a -> ZipSerialM Identity a -> Bool

(/=) :: ZipSerialM Identity a -> ZipSerialM Identity a -> Bool

Ord a => Ord (ZipSerialM Identity a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

compare :: ZipSerialM Identity a -> ZipSerialM Identity a -> Ordering

(<) :: ZipSerialM Identity a -> ZipSerialM Identity a -> Bool

(<=) :: ZipSerialM Identity a -> ZipSerialM Identity a -> Bool

(>) :: ZipSerialM Identity a -> ZipSerialM Identity a -> Bool

(>=) :: ZipSerialM Identity a -> ZipSerialM Identity a -> Bool

max :: ZipSerialM Identity a -> ZipSerialM Identity a -> ZipSerialM Identity a

min :: ZipSerialM Identity a -> ZipSerialM Identity a -> ZipSerialM Identity a

Read a => Read (ZipSerialM Identity a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

readsPrec :: Int -> ReadS (ZipSerialM Identity a)

readList :: ReadS [ZipSerialM Identity a]

readPrec :: ReadPrec (ZipSerialM Identity a)

readListPrec :: ReadPrec [ZipSerialM Identity a]

Show a => Show (ZipSerialM Identity a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

showsPrec :: Int -> ZipSerialM Identity a -> ShowS

show :: ZipSerialM Identity a -> String

showList :: [ZipSerialM Identity a] -> ShowS

a ~ Char => IsString (ZipSerialM Identity a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

fromString :: String -> ZipSerialM Identity a

Semigroup (ZipSerialM m a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

(<>) :: ZipSerialM m a -> ZipSerialM m a -> ZipSerialM m a

sconcat :: NonEmpty (ZipSerialM m a) -> ZipSerialM m a

stimes :: Integral b => b -> ZipSerialM m a -> ZipSerialM m a

Monoid (ZipSerialM m a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

mempty :: ZipSerialM m a

mappend :: ZipSerialM m a -> ZipSerialM m a -> ZipSerialM m a

mconcat :: [ZipSerialM m a] -> ZipSerialM m a

NFData a => NFData (ZipSerialM Identity a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

rnf :: ZipSerialM Identity a -> ()

type Item (ZipSerialM Identity a)

Defined in Streamly.Internal.Data.Stream.Zip

type Item (ZipSerialM Identity a) = a

type ZipSerial = ZipSerialM IO

An IO stream whose applicative instance zips streams serially.

Since: 0.2.0 (Streamly)

Since: 0.8.0

consMZip :: Monad m => m a -> ZipSerialM m a -> ZipSerialM m a

zipWithK :: Monad m => (a -> b -> c) -> Stream m a -> Stream m b -> Stream m c

zipWithMK :: Monad m => (a -> b -> m c) -> Stream m a -> Stream m b -> Stream m c

newtype ZipAsyncM m a

For ZipAsyncM streams:

(<>) = serial
(*) = 'Streamly.Prelude.serial.zipAsyncWith' id

Applicative evaluates the streams being zipped concurrently, the following would take half the time that it would take in serial zipping:

>>> s = Stream.fromFoldableM $ Prelude.map delay [1, 1, 1]
>>> Stream.toList $ Stream.fromZipAsync $ (,) <$> s <*> s
...
[(1,1),(1,1),(1,1)]

Since: 0.2.0 (Streamly)

Since: 0.8.0

Constructors

ZipAsyncM

Fields

• getZipAsyncM :: Stream m a

Instances

IsStream ZipAsyncM

Defined in Streamly.Internal.Data.Stream.IsStream.Type

Methods

toStream :: forall (m :: Type -> Type) a. ZipAsyncM m a -> Stream m a

fromStream :: forall (m :: Type -> Type) a. Stream m a -> ZipAsyncM m a

consM :: MonadAsync m => m a -> ZipAsyncM m a -> ZipAsyncM m a

(|:) :: MonadAsync m => m a -> ZipAsyncM m a -> ZipAsyncM m a

Monad m => Functor (ZipAsyncM m)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

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

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

MonadAsync m => Applicative (ZipAsyncM m)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

pure :: a -> ZipAsyncM m a

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

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

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

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

Semigroup (ZipAsyncM m a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

(<>) :: ZipAsyncM m a -> ZipAsyncM m a -> ZipAsyncM m a

sconcat :: NonEmpty (ZipAsyncM m a) -> ZipAsyncM m a

stimes :: Integral b => b -> ZipAsyncM m a -> ZipAsyncM m a

Monoid (ZipAsyncM m a)

Defined in Streamly.Internal.Data.Stream.Zip

Methods

mempty :: ZipAsyncM m a

mappend :: ZipAsyncM m a -> ZipAsyncM m a -> ZipAsyncM m a

mconcat :: [ZipAsyncM m a] -> ZipAsyncM m a

type ZipAsync = ZipAsyncM IO

An IO stream whose applicative instance zips streams wAsyncly.

Since: 0.2.0 (Streamly)

Since: 0.8.0

consMZipAsync :: Monad m => m a -> ZipAsyncM m a -> ZipAsyncM m a

zipAsyncWithK :: MonadAsync m => (a -> b -> c) -> Stream m a -> Stream m b -> Stream m c

Like zipWith but zips concurrently i.e. both the streams being zipped are evaluated concurrently using the ParallelT concurrent evaluation style. The maximum number of elements of each stream evaluated in advance can be controlled by maxBuffer.

The stream ends if stream a or stream b ends. However, if stream b ends while we are still evaluating stream a and waiting for a result then stream will not end until after the evaluation of stream a finishes. This behavior can potentially be changed in future to end the stream immediately as soon as any of the stream end is detected.

Since: 0.1.0

zipAsyncWithMK :: MonadAsync m => (a -> b -> m c) -> Stream m a -> Stream m b -> Stream m c

Like zipAsyncWith but with a monadic zipping function.

Since: 0.4.0

Deprecated

type ZipStream = ZipSerialM

Deprecated: Please use ZipSerialM instead.

Since: 0.1.0