File tree 1 file changed +1
-19
lines changed
1 file changed +1
-19
lines changed Original file line number Diff line number Diff line change @@ -118,12 +118,7 @@ Connection.prototype._pulseQueryQueue = function(initialConnection) {
118
118
var query = this . _queryQueue . shift ( ) ;
119
119
if ( ! query ) {
120
120
if ( ! initialConnection ) {
121
- //TODO remove all the pause-drain stuff for v1.0
122
- if ( this . _drainPaused ) {
123
- this . _drainPaused ++ ;
124
- } else {
125
- this . emit ( 'drain' ) ;
126
- }
121
+ this . emit ( 'drain' ) ;
127
122
}
128
123
return ;
129
124
}
@@ -145,19 +140,6 @@ Connection.prototype._pulseQueryQueue = function(initialConnection) {
145
140
}
146
141
} ;
147
142
148
- //TODO remove all the pause-drain stuff for v1.0
149
- Connection . prototype . pauseDrain = function ( ) {
150
- this . _drainPaused = 1 ;
151
- } ;
152
-
153
- //TODO remove all the pause-drain stuff for v1.0
154
- Connection . prototype . resumeDrain = function ( ) {
155
- if ( this . _drainPaused > 1 ) {
156
- this . emit ( 'drain' ) ;
157
- }
158
- this . _drainPaused = 0 ;
159
- } ;
160
-
161
143
Connection . prototype . sendCopyFail = function ( msg ) {
162
144
this . endCopyFrom ( msg ) ;
163
145
} ;
You can’t perform that action at this time.
0 commit comments