streamly-core

Streaming, parsers, arrays, serialization and more

https://streamly.composewell.com

LTS Haskell 24.28:0.2.3
Stackage Nightly 2026-01-18:0.3.0
Latest on Hackage:0.3.0

See all snapshots streamly-core appears in

BSD-3-Clause licensed by Composewell Technologies
Maintained by [email protected]
This version can be pinned in stack with:streamly-core-0.3.0@sha256:0cce87e7812242dc570e89531f22bf8fc6bb6b82914cf0fc833113192f5b5224,22516

Module documentation for 0.3.0

  • Streamly
    • Streamly.Console
      • Streamly.Console.Stdio
    • Streamly.Control
      • Streamly.Control.Exception
    • Streamly.Data
      • Streamly.Data.Array
        • Streamly.Data.Array.Generic
      • Streamly.Data.Fold
      • Streamly.Data.MutArray
        • Streamly.Data.MutArray.Generic
      • Streamly.Data.MutByteArray
      • Streamly.Data.Parser
      • Streamly.Data.ParserK
      • Streamly.Data.RingArray
      • Streamly.Data.Scanl
      • Streamly.Data.Stream
      • Streamly.Data.StreamK
      • Streamly.Data.Unfold
    • Streamly.FileSystem
      • Streamly.FileSystem.Dir
      • Streamly.FileSystem.DirIO
      • Streamly.FileSystem.File
      • Streamly.FileSystem.FileIO
      • Streamly.FileSystem.Handle
      • Streamly.FileSystem.Path
    • Streamly.Internal
      • Streamly.Internal.BaseCompat
      • Streamly.Internal.Console
        • Streamly.Internal.Console.Stdio
      • Streamly.Internal.Control
        • Streamly.Internal.Control.Exception
        • Streamly.Internal.Control.ForkIO
        • Streamly.Internal.Control.Monad
      • Streamly.Internal.Data
        • Streamly.Internal.Data.Array
          • Streamly.Internal.Data.Array.Generic
          • Streamly.Internal.Data.Array.Stream
        • Streamly.Internal.Data.Binary
          • Streamly.Internal.Data.Binary.Parser
          • Streamly.Internal.Data.Binary.Stream
        • Streamly.Internal.Data.Builder
        • Streamly.Internal.Data.CString
        • Streamly.Internal.Data.Either
          • Streamly.Internal.Data.Either.Strict
        • Streamly.Internal.Data.Fold
          • Streamly.Internal.Data.Fold.Chunked
        • Streamly.Internal.Data.IOFinalizer
        • Streamly.Internal.Data.IORef
        • Streamly.Internal.Data.IsMap
        • Streamly.Internal.Data.Maybe
          • Streamly.Internal.Data.Maybe.Strict
        • Streamly.Internal.Data.MutArray
          • Streamly.Internal.Data.MutArray.Generic
          • Streamly.Internal.Data.MutArray.Stream
        • Streamly.Internal.Data.MutByteArray
        • Streamly.Internal.Data.Parser
        • Streamly.Internal.Data.ParserK
        • Streamly.Internal.Data.Path
        • Streamly.Internal.Data.Pipe
        • Streamly.Internal.Data.Producer
        • Streamly.Internal.Data.Refold
          • Streamly.Internal.Data.Refold.Type
        • Streamly.Internal.Data.RingArray
          • Streamly.Internal.Data.RingArray.Generic
        • Streamly.Internal.Data.SVar
          • Streamly.Internal.Data.SVar.Type
        • Streamly.Internal.Data.Scanl
        • Streamly.Internal.Data.Scanr
        • Streamly.Internal.Data.Stream
          • Streamly.Internal.Data.Stream.StreamD
        • Streamly.Internal.Data.StreamK
        • Streamly.Internal.Data.Time
          • Streamly.Internal.Data.Time.Clock
          • Streamly.Internal.Data.Time.TimeSpec
          • Streamly.Internal.Data.Time.Units
        • Streamly.Internal.Data.Tuple
          • Streamly.Internal.Data.Tuple.Strict
        • Streamly.Internal.Data.Unfold
      • Streamly.Internal.FileSystem
        • Streamly.Internal.FileSystem.Dir
        • Streamly.Internal.FileSystem.DirIO
        • Streamly.Internal.FileSystem.File
          • Streamly.Internal.FileSystem.File.Common
        • Streamly.Internal.FileSystem.FileIO
        • Streamly.Internal.FileSystem.Handle
        • Streamly.Internal.FileSystem.Path
          • Streamly.Internal.FileSystem.Path.Node
          • Streamly.Internal.FileSystem.Path.Seg
          • Streamly.Internal.FileSystem.Path.SegNode
        • Streamly.Internal.FileSystem.Posix
          • Streamly.Internal.FileSystem.Posix.Errno
          • Streamly.Internal.FileSystem.Posix.File
          • Streamly.Internal.FileSystem.Posix.ReadDir
        • Streamly.Internal.FileSystem.PosixPath
          • Streamly.Internal.FileSystem.PosixPath.Node
          • Streamly.Internal.FileSystem.PosixPath.Seg
          • Streamly.Internal.FileSystem.PosixPath.SegNode
        • Streamly.Internal.FileSystem.Windows
          • Streamly.Internal.FileSystem.Windows.File
          • Streamly.Internal.FileSystem.Windows.ReadDir
        • Streamly.Internal.FileSystem.WindowsPath
          • Streamly.Internal.FileSystem.WindowsPath.Node
          • Streamly.Internal.FileSystem.WindowsPath.Seg
          • Streamly.Internal.FileSystem.WindowsPath.SegNode
      • Streamly.Internal.System
        • Streamly.Internal.System.IO
      • Streamly.Internal.Unicode
        • Streamly.Internal.Unicode.Array
        • Streamly.Internal.Unicode.Parser
        • Streamly.Internal.Unicode.Stream
        • Streamly.Internal.Unicode.String
    • Streamly.Unicode
      • Streamly.Unicode.Parser
      • Streamly.Unicode.Stream
      • Streamly.Unicode.String
Used by 3 packages in nightly-2026-01-18(full list with versions):
streamly, streamly-bytestring, streamly-process

For upgrading to streamly-0.9.0+ please read the Streamly-0.9.0 upgrade guide.

Streamly is a high-performance, beginner-friendly standard library for Haskell. It unifies streaming with list transformers and logic programming; unifies streaming with concurrency and reactive programming; unifies arrays with ring arrays, text, bytestring and vector use cases; unifies arrays with builders and binary serialization; generalizes parsers to any input type and unifies attoparsec, parsec use cases with better performance; provides streaming fileIO — all with a clean, consistent, well-integrated and streaming enabled API.

Streams are designed to have a list like interface — no steep learning curve, no complex types. Streamly is designed to build general purpose applications in a truly functional manner, from simple hello-world to advanced high-performance systems. The design emphasizes simplicity, modularity, and code reuse with minimal building blocks. Performance is on par with C, tuning is easy, and it’s hard to get it wrong.

Streamly is serial by default, with seamless declarative concurrency that scales automatically when needed. It provides prompt and safe resource management, works well with other streaming libraries as well as core libraries like bytestring and text, and is backed by solid documentation.

streamly-core is a Haskell standard library built on top of base and GHC boot libraries only. Stream processing abstractions include streams, scans, folds, parsers; and console IO, file IO; text processing. Array abstractions include pinned, unpinned, mutable, immutable, boxed and unboxed arrays, and ring arrays. Builders, binary serialization, and deserialization are built-in features of arrays.

This package provides a high-performance, unified and ergonomic alternative to many disparate packages, such as streaming, pipes, conduit, list-t, logict, foldl, attoparsec, array, primitive, vector, vector-algorithms, binary, cereal, store, bytestring, text, stringsearch, interpolate, filepath, and path.

Performant. Unified. Modular. Powerful. Simple.

Learn more at the streamly website.

Changes

Changelog

0.3.0

See 0.2.2-0.3.0 API Changelog for a full list of deprecations, additions, and changes to the function signatures.

Enhancements

  • Added APIs for prompt cleanup of resources, allowing guaranteed cleanup as an alternative to GC-based cleanup.
  • Added operations for fair nesting of inner and outer streams for exploring them equally, generally useful but especially useful for logic programming use cases.
  • Introduced Streamly.Data.Scanl with a new Scanl type. Scans can split a stream into multiple streams, process them independently, and merge the results. The Fold type is now split into Fold and Scanl.
  • Added RingArray module for high-performance, unboxed circular buffers.
  • Added Streamly.FileSystem.Path module with a Path type for flexibly typed file system paths.
  • Added Streamly.FileSystem.DirIO and Streamly.FileSystem.FileIO to replace the deprecated Streamly.FileSystem.Dir and Streamly.FileSystem.File. The new modules use Streamly’s native Path type instead of FilePath. DirIO APIs take a ReadOptions argument, and its directory read APIs do not follow symlinks by default.
  • Removed Storable constraint from:
    • Streamly.Data.Stream.isInfixOf
    • Streamly.Data.Array.writeLastN

Deprecations

Following APIs/modules are deprecated and renamed or replaced with new APIs.

  • Streamly.FileSystem.Dir, Streamly.FileSystem.File have been replaced by new modules.
  • Renamed writeN-like APIs to createOf-like in Array modules.
  • Renamed new-like APIs to emptyOf-like in Array modules.
  • In the Fold module renamed indexGeneric, lengthGeneric, and foldlM1' to genericIndex, genericLength, and foldl1M' respectively.

Internal API Changes

  • In Streamly.Internal.Data.Parser, constructors Partial, Continue, and Done are deprecated and replaced with SPartial, SContinue, and SDone. Migration steps:
    • In parser step functions:
      • Partial n -> SPartial (1-n)
      • Continue n -> SContinue (1-n)
      • Done n -> SDone (1-n)
      • Error -> SError
    • Extract function now returns Parser.Final (instead of Parser.Step):
      • Continue n -> FContinue (-n)
      • Done n -> FDone (-n)
      • Partial n -> FContinue (-n)
      • Error -> FError
    • If n is used for decision-making, the logic must be updated accordingly. See docs for details.
  • Internal (mut)array functions now use explicit IO callbacks instead of lifted callbacks.
  • Removed Storable constraint from several ring buffer functions.
  • Added Streamly.Internal.Data.IORef module exposing IORef and related functions.

0.2.2 (Jan 2024)

  • Add fixities infixr 5 for cons and consM functions.
  • Fix a bug in Array Eq instance when the type is a sum type with differently sized constructors.
  • lpackArraysChunksOf, compact, writeChunksWith, putChunksWith now take the buffer size in number of array elements instead of bytes.

0.2.1 (Dec 2023)

  • Make the serialization of the unit constructor deterministic.
  • Expose pinnedSerialize & deserialize via Streamly.Data.Array.

0.2.0 (Nov 2023)

See 0.1.0-0.2.0 API Changelog for a full list of API changes in this release. Only a few significant changes are mentioned here.

Breaking Changes

  • ParserK in Streamly.Data.ParserK is not implicitly specialized to arrays anymore. To adapt to the new code, change ParserK a m b to ParserK (Array a) m b where the Array type comes from Streamly.Data.Array. This change also affected the signatures of parseChunks and parseBreakChunks.
  • Changed the signature of ‘Streamly.Data.Stream.handle’ to make the exception handler monadic.
  • Behavior change: Exceptions are now rethrown promptly in bracketIO.

Enhancements

  • Serialization: Added a Streamly.Data.MutByteArray module with a Serialize type class for fast binary serialization. The Data.Array module supplies the serialize and deserialize operations for arrays.
  • Unpinned Arrays: Unboxed arrays are now created unpinned by default, they were created pinned earlier. During IO operations, unpinned arrays are automatically copied to pinned memory. When arrays are directly passed to IO operations programmers can choose to create them pinned to avoid a copy. To create pinned arrays, use the internal APIs with the pinned* prefix.
  • StreamK now supports native exception handling routines (handle, bracketIO). Earlier we had to convert it to the Stream type for exception handling.

Deprecations

See 0.1.0-0.2.0 API Changelog for a full list of deprecations.

Internal API Changes

  • Fold constructor has changed, added a final field to support finalization and cleanup of a chain of folds. The extract field is now used only for mapping the fold internal state to fold result for scanning purposes. If your fold does not require cleanup you can just use your existing extract function as final as well to adapt to this change.
  • Many low level internal modules have been removed, they are entirely exported from higher level internal modules. If you were importing any of the missing low level modules then import the higher level modules instead.
  • Internal module changes:
    • Streamly.Internal.Serialize.FromBytes -> Streamly.Internal.Data.Binary.Parser
    • Streamly.Internal.Serialize.ToBytes -> Streamly.Internal.Data.Binary.Stream
    • Streamly.Internal.Data.Unbox is now exported via Streamly.Internal.Data.Serialize
    • Streamly.Internal.Data.IORef.Unboxed is now exported via Streamly.Internal.Data.Serialize

0.1.0 (March 2023)

Also see streamly-core-0.1.0 API Changelog or https://hackage.haskell.org/package/streamly-core-0.1.0/docs/docs/ApiChangelogs/0.1.0.txt

streamly package is split into two packages, (1) streamly-core that has only GHC boot library depdendecies, and (2) streamly that contains higher level operations (including concurrent ones) with additional dependencies.

  • Moved the following modules from streamly package to the streamly-core package:
    • Streamly.Console.Stdio
    • Streamly.Data.Fold
    • Streamly.Data.Unfold
    • Streamly.FileSystem.Handle
    • Streamly.Unicode.Stream
  • Added the following new modules:
    • Streamly.Data.Array
    • Streamly.Data.Array.Generic
    • Streamly.Data.MutArray
    • Streamly.Data.MutArray.Generic
    • Streamly.Data.Parser
    • Streamly.Data.ParserK
    • Streamly.Data.Stream
    • Streamly.Data.StreamK
    • Streamly.FileSystem.Dir
    • Streamly.FileSystem.File
    • Streamly.Unicode.Parser
    • Streamly.Unicode.String