Streams deliminator based data from a source converting to an iterator or a list of converted entities
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Failed to load latest commit information.


Build Status Download

Bulk Entity Streaming is a library that streams deliminator based data from a source of various types and provides an iterator or a list of converted entities. The motivation for this library is to provide applications with a consistent way of processing large sources of data (file, http) without the risk of encountering an out of memory exception, no matter how large the source data. The library expects a source function, a deliminator and a function to convert a 'row' (parsed based on the deliminator) of string-based data into an entity.

At the moment this library supports input sources of the following type:

  • Enumerator[Array[Byte]]
  • Future[Enumerator[Array[Byte]]]
  • Iterator[Char]

##Download bulk-entity-streaming

resolvers += Resolver.bintrayRepo("hmrc", "releases")

libraryDependencies += "" %% "bulk-entity-streaming" % "x.x.x"

##Future Enhancements

  • N/A


This code is open source software licensed under the Apache 2.0 License.