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

newtype ZipSerialM m a = ZipSerialM {
- getZipSerialM :: Stream m a
}
type ZipSerial = ZipSerialM IO
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 = ZipAsyncM {
- getZipAsyncM :: Stream m a
}
type ZipAsync = ZipAsyncM IO
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
zipAsyncWithMK :: MonadAsync m => (a -> b -> m c) -> Stream m a -> Stream m b -> Stream m c
type ZipStream = ZipSerialM

Documentation

newtype 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

Constructors

ZipSerialM
Fields getZipSerialM :: Stream m a

Instances

Instances details

IsStream ZipSerialM Source #
Instance details Defined in Streamly.Internal.Data.Stream.IsStream.Type 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

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

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

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

newtype 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

Constructors

ZipAsyncM
Fields getZipAsyncM :: Stream m a

Instances

Instances details

IsStream ZipAsyncM Source #
Instance details Defined in Streamly.Internal.Data.Stream.IsStream.Type 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

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

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

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 Source #

Like zipAsyncWith but with a monadic zipping function.

Since: 0.4.0

Deprecated

type ZipStream = ZipSerialM Source #

Deprecated: Please use ZipSerialM instead.

Since: 0.1.0