Fast, asynchronous, functional reactive stream programming framework with multi‑threading capability based on ES6+.

Master Build StatusMaster Build StatusDependenciesDev DependenciesKnown VulnerabilitiesDeepScan grade
Classes
  • :NumberStream : DataStream

    Simple scramjet stream that by default contains numbers or other containing with valueOf method. The streams provides simple methods like sum, average. It derives from DataStream so it's still fully supporting all map, reduce etc.

    Kind: static class
    Extends: DataStream

    new NumberStream(options)

    Creates an instance of NumberStream.

    Param Type
    options NumberStreamOptions

    numberStream.sum() : Number ⇄

    Calculates the sum of all items in the stream.

    Kind: instance method of NumberStream

    numberStream.avg() : Number ⇄

    Calculates the sum of all items in the stream.

    Kind: instance method of NumberStream