HORIZON HASKELLDocslts/ghc-9.10.x248f8f02026-10-05Search names, modules, packages, or :: a typeCtrl K

GHC 9.10.3 · lts/ghc-9.10.x · 248f8f0 · 2026-10-05

Modulestreamly-0.10.1Haskell2010

Streamly.Internal.Data.Stream.Zip

Deprecated. Use Streamly.Data.Stream.MkType instead.

To run examples in this module:

Example3 expressions
import qualified Streamly.Prelude as Streamimport qualified Streamly.Internal.Data.Stream as Dimport qualified Streamly.Data.Fold as Fold
  • 4 types
  • 3 values
  • Packagestreamly-0.10.1
  • Exports7
  • LanguageHaskell2010
  • LicenceBSD-3-Clause
  • SourceZip.hs
newtypenewtype ZipSerialM (m :: Type -> Type) a
#

For ZipSerialM streams:

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

Applicative evaluates the streams being zipped serially:

Example4 expressions
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)

Constructors

Instances16IsStream, Functor, Applicative, Foldable, Traversable, NFData1, …
typetype ZipSerial = ZipSerialM IO
#

An IO stream whose applicative instance zips streams serially.

Since: 0.2.0 (Streamly)

newtypenewtype ZipConcurrent (m :: Type -> Type) a
#

Constructors

Instances2Functor, Applicative
  • Monad m => Functor (ZipConcurrent m)Defined in streamly-0.10.1 · Streamly.Internal.Data.Stream.Zip
  • MonadAsync m => Applicative (ZipConcurrent m)Defined in streamly-0.10.1 · Streamly.Internal.Data.Stream.Zip

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

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

Deprecated

1 declaration