elastic-stream

elasticsearch streaming wrappers

var searchStream = require('elastic-stream').searchStream
var Query = require('elastic-query')
 
var query = new Query
query.queryString('organization.id:19')
query.sort('timestamp', 'asc')
 
var s = searchStream({
  query: query,
  showProgress: false
})
 
s.pipe(somehwere)