Update packages.

Author: RubenVerborgh

lib/triple-pattern-fragments/TurtleFragmentIterator.js

@@ -11,6 +11,7 @@ function TurtleFragmentIterator(source, fragmentUrl) {
   if (!(this instanceof TurtleFragmentIterator))
     return new TurtleFragmentIterator(source, fragmentUrl);
   TransformIterator.call(this, source);
+  this._fragmentUrl = fragmentUrl;
 
   // Expose an additional metadata stream
   this.metadataStream = new BufferedIterator();
@@ -26,19 +27,24 @@ function TurtleFragmentIterator(source, fragmentUrl) {
 
   // Convert Turtle into triples using the N3 parser
   this._parser = new N3.Parser({ documentURI: fragmentUrl });
-  this._parser.parse(function (error, triple) {
-    if (error)
-      self.emit('error', error);
-    else if (triple)
-      self._processTriple(triple);
+  this._parser.parse({
+    // Use dummy stream to capture `data` and `end` callbacks
+    on: function (event, callback) {
+      if (event === 'data') self._parseData = callback;
+      else if (event === 'end') self._parseEnd = callback;
+    },
+  },
+  // Process each triple and emit possible errors
+  function (error, triple) {
+    if (error) self.emit('error', error);
+    else if (triple) self._processTriple(triple);
   });
-  this._fragmentUrl = fragmentUrl;
 }
 TransformIterator.subclass(TurtleFragmentIterator);
 
 // Sends a chunk of Turtle to the N3 parser to convert it to triples
 TurtleFragmentIterator.prototype._transform = function (chunk, done) {
-  this._parser.addChunk(chunk), done();
+  this._parseData(chunk), done();
 };
 
 // Sends the given parsed triple to the data or metadata stream
@@ -54,7 +60,7 @@ TurtleFragmentIterator.prototype._processTriple = function (triple) {
 // Closes the streams after the source has ended
 TurtleFragmentIterator.prototype._flush = function (done) {
   // Ensure the parser processes possible pending triples
-  this._parser && this._parser.end();
+  this._parseEnd && this._parseEnd();
   // Once all triples have been processed, close both streams
   this.metadataStream.close();
   done();

package.json

@@ -29,7 +29,7 @@
     "lodash": "~2.4.1",
     "lru-cache": "^4.0.1",
     "minimist": "^1.2.0",
-    "n3": "^0.5.0",
+    "n3": "^0.6.0",
     "negotiator": "^0.6.1",
     "parse-link-header": "~0.4.1",
     "setimmediate": "^1.0.4",
@@ -41,9 +41,9 @@
   },
   "devDependencies": {
     "chai": "^3.5.0",
-    "eslint": "^3.0.1",
+    "eslint": "^3.4.0",
     "jsdoc": "^3.4.0",
-    "mocha": "^2.5.3",
+    "mocha": "^3.0.2",
     "pre-commit": "^1.1.3",
     "sinon": "^1.17.4",
     "sinon-chai": "^2.8.0"