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

Master Build StatusMaster Build StatusDependenciesDev DependenciesKnown VulnerabilitiesDeepScan grade
Module exports
Classes
  • WindowStream : DataStream

    A stream for moving window calculation with some simple methods.

    In essence it's a stream of Array's containing a list of items - a window. It's best used when created by the `DataStream..window method.

    Kind: global class
    Extends: DataStream

    windowStream.sum([valueOf]) : Promise.

    Calculates moving sum of items, the output stream will contain the moving sum.

    Kind: instance method of WindowStream
    Chainable

    Param Type Description
    [valueOf] function value of method for array items

    windowStream.avg([valueOf]) : Promise.

    Calculates the moving average of all items in the stream.

    Kind: instance method of WindowStream
    Chainable

    Param Type Description
    [valueOf] function value of method for array items