@@ -165,11 +165,11 @@ let _states = {
165
165
//The transaction is running with no explicit success or failure marked
166
166
ACTIVE : {
167
167
commit : ( connectionHolder , observer ) => {
168
- return { result : _runDiscardAll ( "COMMIT" , connectionHolder , observer ) ,
168
+ return { result : _runPullAll ( "COMMIT" , connectionHolder , observer ) ,
169
169
state : _states . SUCCEEDED }
170
170
} ,
171
171
rollback : ( connectionHolder , observer ) => {
172
- return { result : _runDiscardAll ( "ROLLBACK" , connectionHolder , observer ) , state : _states . ROLLED_BACK } ;
172
+ return { result : _runPullAll ( "ROLLBACK" , connectionHolder , observer ) , state : _states . ROLLED_BACK } ;
173
173
} ,
174
174
run : ( connectionHolder , observer , statement , parameters ) => {
175
175
connectionHolder . getConnection ( ) . then ( conn => {
@@ -250,7 +250,7 @@ let _states = {
250
250
}
251
251
} ;
252
252
253
- function _runDiscardAll ( msg , connectionHolder , observer ) {
253
+ function _runPullAll ( msg , connectionHolder , observer ) {
254
254
connectionHolder . getConnection ( ) . then (
255
255
conn => {
256
256
observer . resolveConnection ( conn ) ;
0 commit comments