|
@ -303,7 +303,7 @@ Readable.prototype.pipe = function(dest, pipeOpts) { |
|
|
state.pipes = dest; |
|
|
state.pipes = dest; |
|
|
break; |
|
|
break; |
|
|
case 1: |
|
|
case 1: |
|
|
state.pipes = [ state.pipes, dest ]; |
|
|
state.pipes = [state.pipes, dest]; |
|
|
break; |
|
|
break; |
|
|
default: |
|
|
default: |
|
|
state.pipes.push(dest); |
|
|
state.pipes.push(dest); |
|
@ -390,7 +390,7 @@ function pipeOnDrain(src) { |
|
|
return function() { |
|
|
return function() { |
|
|
var dest = this; |
|
|
var dest = this; |
|
|
var state = src._readableState; |
|
|
var state = src._readableState; |
|
|
state.awaitDrain --; |
|
|
state.awaitDrain--; |
|
|
if (state.awaitDrain === 0) |
|
|
if (state.awaitDrain === 0) |
|
|
flow(src); |
|
|
flow(src); |
|
|
}; |
|
|
}; |
|
|