Skip to content

Commit 7020a55

Browse files
committed
More doc and fix some file names
1 parent 80a77e0 commit 7020a55

File tree

4 files changed

+12
-4
lines changed

4 files changed

+12
-4
lines changed

README.md

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,13 +40,21 @@ var search = {
4040
var queryExec = client.search.bind(client);
4141
4242
var rs = new ReadableSearch(queryExec, search);
43+
var ws = new require('stream').Writable({objectMode:true});
44+
ws._write = function(chunk, enc, next) {
45+
console.log('a hit', hit);
46+
next();
47+
};
48+
4349
rs.pipe(ws);
4450
```
4551

4652
## TODO
4753
### Short term
4854
* Document more
49-
* Handle errors correctly
55+
* Multi-get as a duplex
56+
* Bulk document errors emitted as errors.
57+
* Search stream: access to total, aggregations etc
5058

5159
## Later
5260
Streaming http client
File renamed without changes.

test/test-search.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
'use strict';
22
var expect = require('chai').expect;
3-
var ReadableHits = require('../lib/readable-hits');
3+
var ReadableSearch = require('..').ReadableSearch;
44
var Writable = require('stream').Writable;
55
var client = new require('elasticsearch').Client();
66

@@ -29,7 +29,7 @@ describe('When searching', function() {
2929
var queryExec = function(params, callback) {
3030
client.search(params, callback);
3131
};
32-
rs = new ReadableHits(queryExec, params);
32+
rs = new ReadableSearch(queryExec, params);
3333
done();
3434
});
3535
});

test/test-write.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
'use strict';
22
var expect = require('chai').expect;
3-
var WritableBulk = require('../lib/writable-bulk');
3+
var WritableBulk = require('..').WritableBulk;
44
var random = require('random-document-stream');
55
var client = new require('elasticsearch').Client();
66

0 commit comments

Comments
 (0)