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

Deprecated

type ZipStream = ZipSerialM

Deprecated: Please use ZipSerialM instead.

Since: 0.1.0