Pinned Repositories
flow-mmean
Transform stream which calculates a sliding-window average (moving-mean) over a numeric data stream.
flow-pcc
Reduce stream which calculates the Pearson product-moment correlation coefficient (PCC) of streamed numeric data.
flow-tcp-client
Factory for creating TCP clients.
flow.io
Collection of Node.js streams.
from-twitter
Provides a stream interface for the Twitter stream API.
map
Transform stream which maps each streamed value to another value.
split
Transform stream which splits streamed data.
split-newline
Transform stream which splits newline delimited data.
to-geckoboard
Transform stream for pushing data to Geckoboard.
to-influxdb
Flow's Repositories
flow-io/flow.io
Collection of Node.js streams.
flow-io/flow-tcp-client
Factory for creating TCP clients.
flow-io/flow-csum
Transform stream factory to calculate the cumulative sum of a numeric data stream.
flow-io/flow-diff
Transform stream factory to calculate the difference between successive streamed data values.
flow-io/flow-mmean
Transform stream which calculates a sliding-window average (moving-mean) over a numeric data stream.
flow-io/append-node
Transform stream which appends to each data string.
flow-io/flow-add
Transform stream factory to increment streamed numeric data values.
flow-io/flow-chunkify
Transform stream factory to chunk streamed data values.
flow-io/flow-cmean
Transform stream factory to calculate arithmetic means for streamed data arrays (chunks).
flow-io/flow-kurtosis
Reduce stream factory to calculate the sample excess kurtosis of streamed data values.
flow-io/flow-mgmean
Transform stream factory that finds the geometric mean of numeric streamed data in a moving window
flow-io/flow-mhmean
Transform stream factory to calculate a sliding-window harmonic mean over a numeric data stream.
flow-io/flow-mock-read
Provides a mock sink for readable streams.
flow-io/flow-mock-write
Provides a mock source for writable streams.
flow-io/flow-skewness
Reduce stream factory to calculate the sample skewness of streamed data values.
flow-io/flow-tcp-marshal
Transform stream factory to format data for TCP transmission.
flow-io/flow-tcp-server
Thin wrapper for creating TCP servers.
flow-io/flow-tcp-unmarshal
Transform stream factory to unmarshal TCP transmitted data.
flow-io/from-array-node
Converts an array to a readable stream.
flow-io/from-string-node
Converts a string to a readable stream.
flow-io/tostring-node
Transform stream which converts each datum to a string.
flow-io/contributing
A guide to contributing to Flow.io.
flow-io/flow-abs
Transform stream factory to map numeric data stream values to their absolute values.
flow-io/flow-ceil
Transform stream factory to round streamed numeric data values toward positive infinity (ceil).
flow-io/flow-divide
Transform stream factory to perform scalar division on streamed numeric data values.
flow-io/flow-exp
Transform stream factory to evaluate an exponential function for each numeric data value.
flow-io/flow-gmean
flow-io/flow-pow
Transform stream factory to exponentiate numeric data stream values according a specified power.
flow-io/flow-sink-and-stream
Transform stream factory to sink a specified number of streamed data values and then stream new data values as they arrive.
flow-io/flow-subtract
Transform stream factory to decrement streamed numeric data values.