File tree 1 file changed +5
-4
lines changed
1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -196,7 +196,8 @@ p._pulseQueryQueue = function() {
196
196
this . activeQuery . submit ( this . connection ) ;
197
197
} else if ( this . hasExecuted ) {
198
198
this . activeQuery = null ;
199
- this . _drainPaused > 0 ? this . _drainPaused ++ : this . emit ( 'drain' )
199
+ if ( this . _drainPaused > 0 ) { this . _drainPaused ++ ; }
200
+ else { this . emit ( 'drain' ) ; }
200
201
}
201
202
}
202
203
} ;
@@ -211,7 +212,7 @@ p._copy = function (text, stream) {
211
212
} else {
212
213
config . stream . close ( ) ;
213
214
}
214
- }
215
+ } ;
215
216
query = new Query ( config ) ;
216
217
this . queryQueue . push ( query ) ;
217
218
this . _pulseQueryQueue ( ) ;
@@ -220,10 +221,10 @@ p._copy = function (text, stream) {
220
221
} ;
221
222
p . copyFrom = function ( text ) {
222
223
return this . _copy ( text , new CopyFromStream ( ) ) ;
223
- }
224
+ } ;
224
225
p . copyTo = function ( text ) {
225
226
return this . _copy ( text , new CopyToStream ( ) ) ;
226
- }
227
+ } ;
227
228
p . query = function ( config , values , callback ) {
228
229
//can take in strings, config object or query object
229
230
var query = ( config instanceof Query ) ? config : new Query ( config , values , callback ) ;
You can’t perform that action at this time.
0 commit comments