Added queryStream method

biolab-unige · Nov 22, 2016 · a48fd03 · a48fd03
1 parent a6a2682
commit a48fd03
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/crud/WtCrudStrategies.js b/lib/crud/WtCrudStrategies.js
@@ -11,6 +11,7 @@
 
 const PG = 'pg';
 let BluebirdPromise = require('bluebird');
+let fs = require('fs');
 let FileSystemManager = require('xtens-fs').FileSystemManager;
 let _ = require("lodash");
 
@@ -121,8 +122,8 @@ class WtPromiseCrudStrategy extends WtCrudStrategy {
     }
 
     queryStream(statement, parameters, next) {
-
-        return global.sails.models.data.stream({statement: statement, parameters: parameters}, next);
+        let stream = fs.createReadStream('./test/resources/data.json', {encoding: 'utf8'});
+        return next(stream,null);
     }
 }