File tree Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -46,8 +46,8 @@ session.run(statement.join(' '), params).subscribe({
46
46
for (var i in record) {
47
47
console .log (i, ' : ' , record[i]);
48
48
}
49
- }, onCompleted : function (metadata ) {
50
- console . log (metadata );
49
+ }, onCompleted : function () {
50
+ session . close ( );
51
51
}, onError : function (error ) {
52
52
console .log (error);
53
53
}
@@ -61,7 +61,8 @@ session.run(statement.join(' '), params)
61
61
for (var i in record) {
62
62
console .log (i, ' : ' , record[i]);
63
63
}
64
- })
64
+ });
65
+ session .close ();
65
66
})
66
67
.catch (function (error ) {
67
68
console .log (error);
Original file line number Diff line number Diff line change @@ -94,7 +94,7 @@ class Result {
94
94
let onCompletedOriginal = observer . onCompleted ;
95
95
let onCompletedWrapper = ( metadata ) => {
96
96
this . summary = new ResultSummary ( this . _statement , this . _parameters , metadata ) ;
97
- onCompletedOriginal . call ( observer , metadata ) ;
97
+ onCompletedOriginal . call ( observer ) ;
98
98
}
99
99
observer . onCompleted = onCompletedWrapper ;
100
100
this . _streamObserver . subscribe ( observer ) ;
You can’t perform that action at this time.
0 commit comments