How to use the extend function from highland

finance-stream.js

GitHub: xat/finance-stream

112
113
114
115
116
117
118
119
120
121
    if (data === _.nil || !has(where, data)) {
      next();
      return;
    }
    args.forEach(function(obj) {
      push(null, _.extend(obj, data));
    });
    next();
  });
};

2

15

4

ddocs.js

GitHub: jo/couch-daemon

40
41
42
43
44
45
46
47
48
49
source.pause();

getDdocs(data.db_name, function(err, resp) {
  if (!err) {
    resp.rows.forEach(function(row) {
      var d = _.extend({ stream: 'ddocs', db_name: data.db_name }, row);

      push(null, d);
    });
  }

2

14

3