peer: fix handleDrain.
This commit is contained in:
parent
592191c44c
commit
caf8043dcb
@ -1175,10 +1175,11 @@ Peer.prototype.handleDrain = function handleDrain() {
|
||||
var jobs = this.drainQueue;
|
||||
var i, job;
|
||||
|
||||
this.drainSize = 0;
|
||||
|
||||
if (jobs.length === 0)
|
||||
return;
|
||||
|
||||
this.drainSize = 0;
|
||||
this.drainQueue = [];
|
||||
|
||||
for (i = 0; i < jobs.length; i++) {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user