Make the constrctor factories too. Bump version

Author: hmalphettes

lib/readable-search.js

@@ -14,6 +14,9 @@ module.exports = ReadableHits;
  * @param queryExec an executable query functions that takes 2 arguments: the offset and a callback.
  */
 function ReadableHits(queryExec) {
+  if (!(this instanceof ReadableHits)) {
+    return new ReadableHits(queryExec);
+  }
   Readable.call(this, {objectMode:true});
   this.queryExec = queryExec;
   this.total = -1;

lib/transform-mget.js

@@ -9,9 +9,12 @@ module.exports = PipableDocs;
 /**
  * @param mgetExec an executable query functions that takes 2 arguments:
  *       a list of document IDs and a callback.
- * @param bulkSize number of bulk commands executed at once. 128 by default.
+ * @param corkSize number of documents fetched at once. 128 by default.
  */
 function PipableDocs(mgetExec, corkSize) {
+  if (!(this instanceof PipableDocs)) {
+    return new PipableDocs(mgetExec);
+  }
   Transform.call(this, {objectMode:true});
   this.mgetExec = mgetExec;
   this.corkSize = corkSize;

lib/transform-to-bulk.js

@@ -12,6 +12,9 @@ module.exports = TransformToBulk;
  *            { _index: the_index?, _type: the_type?, _id: the_id? }
  */
 function TransformToBulk(getIndexTypeId) {
+  if (!(this instanceof TransformToBulk)) {
+    return new TransformToBulk(getIndexTypeId);
+  }
   Transform.call(this, {objectMode:true});
   this.getIndexTypeId = getIndexTypeId;
 }

lib/writable-bulk.js

@@ -12,6 +12,9 @@ module.exports = WritableBulk;
  * @param highWaterMark number of bulk commands executed at once. 128 by default.
  */
 function WritableBulk(bulkExec, highWaterMark) {
+  if (!(this instanceof WritableBulk)) {
+    return new WritableBulk(bulkExec, highWaterMark);
+  }
   Writable.call(this, {objectMode:true});
   this.bulkExec = bulkExec;
 

package.json

@@ -1,7 +1,7 @@
 {
   "name": "elasticsearch-streams",
   "description": "Stream in and out of Elasticsearch",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "repository": {
     "type": "git",
     "url": "https://github.com/hmalphettes/elasticsearch-streamer.git"