Skip to content

Commit

Permalink
Moved from " to '.
Browse files Browse the repository at this point in the history
  • Loading branch information
mcollina committed Nov 24, 2013
1 parent 6d471a3 commit 19f89e4
Show file tree
Hide file tree
Showing 14 changed files with 366 additions and 366 deletions.
2 changes: 1 addition & 1 deletion lib/getdb-browser.js
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@

var Leveljs = require("level-js");
var Leveljs = require('level-js');
module.exports = function(l) { return new Leveljs(l); };
20 changes: 10 additions & 10 deletions lib/joinstream.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@

var Transform = require("./streamwrapper").Transform
, Variable = require("./variable")
, utilities = require("./utilities")
var Transform = require('./streamwrapper').Transform
, Variable = require('./variable')
, utilities = require('./utilities')
, queryMask = utilities.queryMask
, variablesMask = utilities.variablesMask
, maskUpdater
Expand All @@ -24,9 +24,9 @@ function JoinStream(options) {
this._index = options.index;

var that = this;
this.once("pipe", function(source) {
source.on("error", function(err) {
that.emit("error", err);
this.once('pipe', function(source) {
source.on('error', function(err) {
that.emit('error', err);
});
});
}
Expand All @@ -43,19 +43,19 @@ JoinStream.prototype._transform = function(solution, encoding, done) {
var newMask = this.maskUpdater(solution, this.mask);
var readStream = this.db.getStream(newMask, { index: this._index });

readStream.on("data", function(triple) {
readStream.on('data', function(triple) {
var newsolution = that.matcher(solution, triple);

if (newsolution) {
that.push(newsolution);
}
});

readStream.on("error", function(err) {
that.emit("error", err);
readStream.on('error', function(err) {
that.emit('error', err);
});

readStream.on("end", done);
readStream.on('end', done);
};

module.exports = JoinStream;
Expand Down
4 changes: 2 additions & 2 deletions lib/keyfilterstream.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@

var Transform = require("./streamwrapper").Transform;
var Transform = require('./streamwrapper').Transform;

function KeyFilterStream(options) {
if (!(this instanceof KeyFilterStream)) {
Expand All @@ -14,7 +14,7 @@ function KeyFilterStream(options) {

var that = this;

this.once("pipe", function(source) {
this.once('pipe', function(source) {
that.source = source;
});

Expand Down
4 changes: 2 additions & 2 deletions lib/materializerstream.js
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@

var Transform = require("./streamwrapper").Transform
, materializer = require("./utilities").materializer;
var Transform = require('./streamwrapper').Transform
, materializer = require('./utilities').materializer;

function MaterializerStream(options) {
if (!(this instanceof MaterializerStream)) {
Expand Down
10 changes: 5 additions & 5 deletions lib/queryplanner.js
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

var utilities = require("./utilities")
var utilities = require('./utilities')
, queryMask = utilities.queryMask
, variablesMask = utilities.variablesMask
, JoinStream = require("./joinstream")
, SortJoinStream = require("./sortjoinstream")
, JoinStream = require('./joinstream')
, SortJoinStream = require('./sortjoinstream')
, doSortQueryPlan
, async = require("async");
, async = require('async');

function orderedPossibleIndex(keys) {
return Object.keys(utilities.defs).filter(function(index) {
Expand Down Expand Up @@ -57,7 +57,7 @@ function queryplanner(db, options) {
delete q.size;
});

if (options.joinAlgorithm === "sort" && result.length > 1) {
if (options.joinAlgorithm === 'sort' && result.length > 1) {
result.reduce(doSortQueryPlan);
}

Expand Down
Loading

0 comments on commit 19f89e4

Please sign in to comment.