File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -11,6 +11,7 @@ Examples:
11
11
12
12
## Stream random records into Elasticsearch
13
13
```
14
+ var WritableBulk = require('elasticsearch-streams').WritableBulk;
14
15
var client = new require('elasticsearch').Client();
15
16
16
17
var bulkExec = function(bulkCmds, callback) {
@@ -28,7 +29,7 @@ require('random-document-stream')(42).pipe(ws);
28
29
29
30
## Stream search results from Elasticsearch
30
31
```
31
- var ReadableSearch = require('elasticsearch-streams')
32
+ var ReadableSearch = require('elasticsearch-streams').ReadableSearch;
32
33
var client = new require('elasticsearch').Client();
33
34
34
35
var search = {
@@ -59,7 +60,7 @@ rs.pipe(ws);
59
60
* Search stream: access to total, aggregations etc
60
61
61
62
## Later
62
- Streaming http client
63
+ Streaming http client or transport
63
64
64
65
# LICENSE
65
66
elasticsearch-streams is freely distributable under the terms of the MIT license.
You can’t perform that action at this time.
0 commit comments