Remove streams

Author: jbmusso

package.json

@@ -35,10 +35,8 @@
   "homepage": "https://github.com/jbmusso/gremlin-javascript",
   "dependencies": {
     "gremlin-template-string": "^2.0.0",
-    "highland": "^2.5.1",
     "lodash": "^3.10.1",
     "node-uuid": "^1.4.3",
-    "readable-stream": "^2.0.2",
     "rx": "^4.1.0",
     "ws": "^2.3.1"
   },

src/GremlinClient.js

@@ -4,10 +4,8 @@ import { EventEmitter } from 'events';
 
 import uuid from 'node-uuid';
 import _ from 'lodash';
-import highland from 'highland';
 
 import WebSocketGremlinConnection from './WebSocketGremlinConnection';
-import MessageStream from './MessageStream';
 import * as Utils from './utils';
 
 import Rx from 'rx';
@@ -216,9 +214,6 @@ class GremlinClient extends EventEmitter {
    * Asynchronously send a script to Gremlin Server for execution and fire
    * the provided callback when all results have been fetched.
    *
-   * This method internally uses a stream to handle the potential concatenation
-   * of results.
-   *
    * Callback signature: (Error, Array<result>)
    *
    * @public

src/MessageStream.js

@@ -13,19 +13,6 @@ describe('Bindings', function() {
     });
   });
 
-  it.skip('should support bindings with client.stream()', function(done) {
-    var client = gremlin.createClient();
-    var stream = client.stream('g.V(x)', { x: 1 });
-
-    stream.on('data', function(result) {
-      result.id.should.equal(1);
-    });
-
-    stream.on('end', function() {
-      done();
-    });
-  });
-
   it.skip('should give an error with reserved binding name in .exec', function(done) {
     var client = gremlin.createClient();
 

src/executeHandler.js

@@ -56,24 +56,6 @@ describe('.createClient()', function() {
     client.options.aliases.should.eql({ h: 'g' });
   });
 
-  it.skip('should override a set `processor` option on a per request basis', function(done) {
-    var client = gremlin.createClient({ op: 'foo' });
-
-    client.port.should.equal(8182);
-    client.host.should.equal('localhost');
-    client.options.op.should.equal('foo');
-
-    var s = client.stream('g.V(1)', null, { op: 'eval' });
-
-    s.on('data', function(result) {
-      result.should.be.an('object');
-    });
-
-    s.on('end', function() {
-      done();
-    });
-  });
-
   describe('WebSocket path', () => {
     it('should support a custom websocket path', () => {
       const client = gremlin.createClient({ path: '/foo/bar' });