How to use the through function from highland

ddocs.js

GitHub: jo/couch-daemon

23
24
25
26
27
28
29
30
31
32
    endkey: '_design0',
    include_docs: true
  }, done);
}

return _.through(function(source) {
  var sourceEnded = false;

  var target = _(function(push, done) {
    // on db create, or update

2

14

3

index.js

GitHub: zoellner/gmail-batch-stream

174
175
176
177
178
179
180
181
182
183
};

const processingPipeline = function(filterErrors) {
  return _h.pipeline(
    _h.invoke('toString', ['utf8']),
    _h.through(parseMultiPart()),
    _h.map(parseHttpResponse),
    _h.map(function(doc) {
      if (filterErrors && !(doc && doc.statusCode && parseInt(doc.statusCode, 10) === 200)) {
        return null;

2

8

0