Copyright	(c) 2017 Composewell Technologies
License	BSD3
Maintainer	streamly@composewell.com
Stability	experimental
Portability	GHC
Safe Haskell	None
Language	Haskell2010

Streamly.Internal.Data.Stream.Zip

Contents

Deprecated

Description

To run examples in this module:

>>> import qualified Streamly.Prelude as Stream

Synopsis

data ZipSerialM m a
type ZipSerial = ZipSerialM IO
fromZipSerial :: IsStream t => ZipSerialM m a -> t m a
data ZipAsyncM m a
type ZipAsync = ZipAsyncM IO
fromZipAsync :: IsStream t => ZipAsyncM m a -> t m a
zipWith :: (IsStream t, Monad m) => (a -> b -> c) -> t m a -> t m b -> t m c
zipWithM :: (IsStream t, Monad m) => (a -> b -> m c) -> t m a -> t m b -> t m c
zipAsyncWith :: (IsStream t, MonadAsync m) => (a -> b -> c) -> t m a -> t m b -> t m c
zipAsyncWithM :: (IsStream t, MonadAsync m) => (a -> b -> m c) -> t m a -> t m b -> t m c
type ZipStream = ZipSerialM
zipping :: IsStream t => ZipSerialM m a -> t m a
zippingAsync :: IsStream t => ZipAsyncM m a -> t m a

Documentation

data ZipSerialM m a Source #

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

Instances

Instances details

IsStream ZipSerialM Source #
Instance details Defined in Streamly.Internal.Data.Stream.Zip Methods toStream :: forall (m :: Type -> Type) a. ZipSerialM m a -> Stream m a Source # fromStream :: forall (m :: Type -> Type) a. Stream m a -> ZipSerialM m a Source # consM :: MonadAsync m => m a -> ZipSerialM m a -> ZipSerialM m a Source # (\|:) :: MonadAsync m => m a -> ZipSerialM m a -> ZipSerialM m a Source #
Monad m => Functor (ZipSerialM m) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details Defined in Streamly.Internal.Data.Stream.Zip Methods liftRnf :: (a -> ()) -> ZipSerialM Identity a -> () #
IsList (ZipSerialM Identity a) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details Defined in Streamly.Internal.Data.Stream.Zip Methods fromString :: String -> ZipSerialM Identity a #
Semigroup (ZipSerialM m a) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details Defined in Streamly.Internal.Data.Stream.Zip Methods rnf :: ZipSerialM Identity a -> () #
type Item (ZipSerialM Identity a) Source #
Instance details Defined in Streamly.Internal.Data.Stream.Zip type Item (ZipSerialM Identity a) = a

type ZipSerial = ZipSerialM IO Source #

An IO stream whose applicative instance zips streams serially.

Since: 0.2.0 (Streamly)

Since: 0.8.0

fromZipSerial :: IsStream t => ZipSerialM m a -> t m a Source #

Fix the type of a polymorphic stream as ZipSerialM.

Since: 0.2.0 (Streamly)

Since: 0.8.0

data ZipAsyncM m a Source #

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

Instances

Instances details

IsStream ZipAsyncM Source #
Instance details Defined in Streamly.Internal.Data.Stream.Zip Methods toStream :: forall (m :: Type -> Type) a. ZipAsyncM m a -> Stream m a Source # fromStream :: forall (m :: Type -> Type) a. Stream m a -> ZipAsyncM m a Source # consM :: MonadAsync m => m a -> ZipAsyncM m a -> ZipAsyncM m a Source # (\|:) :: MonadAsync m => m a -> ZipAsyncM m a -> ZipAsyncM m a Source #
Monad m => Functor (ZipAsyncM m) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details 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) Source #
Instance details 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 Source #

An IO stream whose applicative instance zips streams wAsyncly.

Since: 0.2.0 (Streamly)

Since: 0.8.0

fromZipAsync :: IsStream t => ZipAsyncM m a -> t m a Source #

Fix the type of a polymorphic stream as ZipAsyncM.

Since: 0.2.0 (Streamly)

Since: 0.8.0

zipWith :: (IsStream t, Monad m) => (a -> b -> c) -> t m a -> t m b -> t m c Source #

Zip two streams serially using a pure zipping function.

> S.toList $ S.zipWith (+) (S.fromList [1,2,3]) (S.fromList [4,5,6])
[5,7,9]

Since: 0.1.0

zipWithM :: (IsStream t, Monad m) => (a -> b -> m c) -> t m a -> t m b -> t m c Source #

Like zipWith but using a monadic zipping function.

Since: 0.4.0

zipAsyncWith :: (IsStream t, MonadAsync m) => (a -> b -> c) -> t m a -> t m b -> t m c Source #

Like zipWith but zips concurrently i.e. both the streams being zipped are generated concurrently.

Since: 0.1.0

zipAsyncWithM :: (IsStream t, MonadAsync m) => (a -> b -> m c) -> t m a -> t m b -> t m c Source #

Like zipWithM but zips concurrently i.e. both the streams being zipped are generated concurrently.

Since: 0.4.0

Deprecated

type ZipStream = ZipSerialM Source #

Deprecated: Please use ZipSerialM instead.

Since: 0.1.0

zipping :: IsStream t => ZipSerialM m a -> t m a Source #

Deprecated: Please use fromZipSerial instead.

Same as fromZipSerial.

Since: 0.1.0

zippingAsync :: IsStream t => ZipAsyncM m a -> t m a Source #

Deprecated: Please use fromZipAsync instead.

Same as fromZipAsync.

Since: 0.1.0