Make .observable() emit results rather than incoming messages

Author: jbmusso

src/GremlinClient.js

@@ -217,7 +217,6 @@ class GremlinClient extends EventEmitter {
     }
 
     this.observable(script, bindings, message)
-      .flatMap(({ result: { data }}) => data)
       .toArray()
       .subscribe(
         (results) => callback(null, results),
@@ -326,6 +325,8 @@ class GremlinClient extends EventEmitter {
         noContentMessage$,
         errorMessages$
       )
+      .flatMap(({ result: { data }}) => data)
+
       .takeUntil(terminationMessages$);
 
     return results$;