Compatibility with RethinkDB v1.13+

README.md

@@ -22,7 +22,7 @@ r.connect( //...
 // Make a query to get a cursor
 r.table('myTable').run(connection, function(err, cursor) {
   var stream = new CursorStream(cursor);
-  cursor.pipe(//... do whatever you want with your stream !
+  stream.pipe(//... do whatever you want with your stream !
 });
 ```
 

index.js

@@ -16,17 +16,17 @@ function CursorStream(cursor) {
 }
 
 CursorStream.prototype._read = function read() {
-  if (!(this._cursor && this._cursor.hasNext())) {
-    this.push(null);
-    return;
-  }
   this._cursor.next(function (err, item) {
     if (err) {
+      if (((err.name === "RqlDriverError") && err.message === "No more rows in the cursor.")) {
+        this.push(null);
+        return;
+      }
       this.emit('error', err);
       return;
     }
     if (this.push(item)) {
       read.bind(this);
     }
   }.bind(this));
-};
+};