flow-io/flow.io

rawStream.pipe(JSONStream.parse()).pipe(streamOfObjects)

construct pipes of streams of events

A drop-in replacement for fs, making various improvements.

A tiny wrapper around Node.js streams.Transform (Streams2/3) to avoid explicit subclassing noise

simplified stream construction

Transform stream factory to chunk streamed data values.

Reduce transform stream which calculates the covariance of streamed numeric data.

Transform stream factory to map numeric data stream values to their absolute values.

Transform stream factory to increment streamed numeric data values.

Reduce transform stream which computes a histogram over streamed data.

Writable stream which transforms an array into a readable stream.

Reduce transform stream which calculates the interquartile range over streamed data.

Transform stream factory to round streamed numeric data values toward positive infinity (ceil).

Reduce stream factory to calculate the sample excess kurtosis of streamed data values.

Transform stream which returns the total number of streamed data.

Transform stream factory to calculate the difference between successive streamed data values.

Reduce transform stream which calculates the mean of streamed data.

Transform stream factory to calculate arithmetic means for streamed data arrays (chunks).

Reduce transform stream which calculates the median of streamed data.

Transform stream which filters stream data according to user-defined conditions.

Transform stream factory to evaluate an exponential function for each numeric data value.

Transform stream which calculates the cumulative sum of a numeric data stream.

Transform stream factory to perform scalar division on streamed numeric data values.

Provides a mock sink for readable streams.

Provides a mock source for writable streams.

Transform stream which maps each streamed value to another value.

Transform stream which returns the maximum value from a stream of numeric data.

Reduce transform stream which calculates the Pearson product-moment correlation coefficient matrix of streamed numeric data.

Transform stream which calculates a sliding-window average (moving-mean) over a numeric data stream.

Transform stream factory to floor streamed numeric data values.

Transform stream factory to find sliding-window maximum values (moving max) over a numeric data stream.

Reduce transform stream which calculates quantiles over streamed data.

Transform stream factory to find sliding-window minimum values (moving min) over a numeric data stream.

Through stream which performs a data reduction.

Transform stream which returns the minimum value from a stream of numeric data.

Transform stream which calculates a sliding-window sum (moving-sum) over a numeric data stream.

Transform stream factory to perform scalar multiplication on streamed numeric data values.

Reduce stream factory to calculate the sample skewness of streamed data values.

Through stream which removes all non-numeric values from a stream.

Transform stream factory to exponentiate numeric data stream values according a specified power.

Reduce transform stream which calculates the variance of streamed data.

Thin wrapper for JSONStream parse.

Thin wrapper for graceful-fs file read stream.

Transform stream factory to sink a specified number of streamed data values and then stream new data values as they arrive.

Thin wrapper for JSON stream stringify.

Transform stream factory to round streamed numeric data values.

Transform stream factory to decrement streamed numeric data values.

Transform stream which returns the summation of streamed numeric data.

Thin wrapper for graceful-fs file write stream.