hypercore-reduce v1.0.0

hypercore-reduce

Reduce from an initial state as a function of a hypercore

Usage

var reduce = require('hypercore-reduce')

var initial = {}
// Feed is a hypercore instance
reduce(feed, reducer, initial, done)

function reducer (prevState, curState, next) {
  return next(null, Object.assign(prevState, curState))
}

function done (err, finalState) {
  if (err) throw err

  console.log(finalState)
}

API

var destroy = reduce(feed, [readOpts], reducer, initial, done)

Reduce a hypercore feed from an initial state initial, calling reducer(state, currentItem, callback), where callback(err, state) will update the state. When the feed is completely consumed, done(err, state) will be invoked with the final state. If an error occurs, done is also invoked. Optionally readOpts can be passed as argument to feed.createReadStream.

A destroy(err) function is returned, which can be used to destroy the underlying stream.

Install

npm install hypercore-reduce

License

ISC