Keep context in subscribe methods.

Author: oskarhane

lib/result.js

@@ -94,7 +94,7 @@ class Result {
     let onCompletedOriginal = observer.onCompleted;
     let onCompletedWrapper = (metadata) => {
       this.summary = new ResultSummary(this._statement, this._parameters, metadata);
-      onCompletedOriginal(metadata);
+      onCompletedOriginal.call(observer, metadata);
     }
     observer.onCompleted = onCompletedWrapper;
     this._streamObserver.subscribe(observer);

test/session.test.js

@@ -22,6 +22,28 @@ describe('session', function() {
     });
   });
 
+  it('should keep context in subscribe methods ', function(done) {
+    // Given
+    var driver = neo4j.driver("neo4j://localhost");
+    function myObserver(){
+      this.local = 'hello';
+      var privateLocal = 'hello';
+      this.onNext = function() {
+        expect(privateLocal).toBe('hello');
+        expect(this.local).toBe('hello');
+      };
+      this.onCompleted = function() {
+        expect(privateLocal).toBe('hello');
+        expect(this.local).toBe('hello');
+        driver.close();
+        done();
+      }
+    }
+    
+    // When & Then
+    driver.session().run( "RETURN 1.0 AS a").subscribe(new myObserver());
+  });
+
   it('should call observers onError on error ', function(done) {
     // Given
     var driver = neo4j.driver("neo4j://localhost");