red-rings-couchdb/util/view-stream.js

// Generated by CoffeeScript 2.3.1
(function() {
  // CouchDB view as a stream of `row`
  // ---------------
  var oboe, oboe_stream, oboe_stream_request, request, view_stream;

  view_stream = function(db_uri, app, view, params) {
    var n, r, uri;
    if (app != null) {
      uri = `${db_uri}/_design/${app}/_view/${view}`;
    } else {
      uri = `${db_uri}/${view}`;
    }
    n = oboe_stream_request({
      url: uri,
      qs: params
    });
    r = oboe_stream('rows.*', n);
    n.node('rows.*', function() {
      return oboe.drop;
    });
    return r;
  };

  module.exports = view_stream;

  oboe_stream = require('oboe-as-stream');

  oboe = require('oboe');

  request = require('request');

  oboe_stream_request = (require('oboe-stream-request'))(oboe, request);

}).call(this);