| 1 | CouchDB view as a stream of `row`
|
| 2 | ---------------
|
| 3 |
|
| 4 | view_stream = (db_uri,app,view,params) ->
|
| 5 |
|
| 6 | if app?
|
| 7 | uri = "#{db_uri}/_design/#{app}/_view/#{view}"
|
| 8 | else
|
| 9 | uri = "#{db_uri}/#{view}"
|
| 10 |
|
| 11 | n = oboe_stream_request url:uri,qs:params
|
| 12 |
|
| 13 | r = oboe_stream 'rows.*', n
|
| 14 | n.node 'rows.*', -> oboe.drop
|
| 15 | r
|
| 16 |
|
| 17 | module.exports = view_stream
|
| 18 | oboe_stream = require 'oboe-as-stream'
|
| 19 | oboe = require 'oboe'
|
| 20 | request = require 'request'
|
| 21 | oboe_stream_request = (require 'oboe-stream-request') oboe, request
|