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({
4646 for (var i in record) {
4747 console .log (i, ' : ' , record[i]);
4848 }
49- }, onCompleted : function (metadata ) {
50- console . log (metadata );
49+ }, onCompleted : function () {
50+ session . close ( );
5151 }, onError : function (error ) {
5252 console .log (error);
5353 }
@@ -61,7 +61,8 @@ session.run(statement.join(' '), params)
6161 for (var i in record) {
6262 console .log (i, ' : ' , record[i]);
6363 }
64- })
64+ });
65+ session .close ();
6566 })
6667 .catch (function (error ) {
6768 console .log (error);
Original file line number Diff line number Diff line change @@ -94,7 +94,7 @@ class Result {
9494 let onCompletedOriginal = observer . onCompleted ;
9595 let onCompletedWrapper = ( metadata ) => {
9696 this . summary = new ResultSummary ( this . _statement , this . _parameters , metadata ) ;
97- onCompletedOriginal . call ( observer , metadata ) ;
97+ onCompletedOriginal . call ( observer ) ;
9898 }
9999 observer . onCompleted = onCompletedWrapper ;
100100 this . _streamObserver . subscribe ( observer ) ;
You can’t perform that action at this time.
0 commit comments