File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed
Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -196,7 +196,8 @@ p._pulseQueryQueue = function() {
196196 this . activeQuery . submit ( this . connection ) ;
197197 } else if ( this . hasExecuted ) {
198198 this . activeQuery = null ;
199- this . _drainPaused > 0 ? this . _drainPaused ++ : this . emit ( 'drain' )
199+ if ( this . _drainPaused > 0 ) { this . _drainPaused ++ ; }
200+ else { this . emit ( 'drain' ) ; }
200201 }
201202 }
202203} ;
@@ -211,7 +212,7 @@ p._copy = function (text, stream) {
211212 } else {
212213 config . stream . close ( ) ;
213214 }
214- }
215+ } ;
215216 query = new Query ( config ) ;
216217 this . queryQueue . push ( query ) ;
217218 this . _pulseQueryQueue ( ) ;
@@ -220,10 +221,10 @@ p._copy = function (text, stream) {
220221} ;
221222p . copyFrom = function ( text ) {
222223 return this . _copy ( text , new CopyFromStream ( ) ) ;
223- }
224+ } ;
224225p . copyTo = function ( text ) {
225226 return this . _copy ( text , new CopyToStream ( ) ) ;
226- }
227+ } ;
227228p . query = function ( config , values , callback ) {
228229 //can take in strings, config object or query object
229230 var query = ( config instanceof Query ) ? config : new Query ( config , values , callback ) ;
You can’t perform that action at this time.
0 commit comments