()
| 518 | } |
| 519 | |
| 520 | function drain() { |
| 521 | while(buffer.length && !stream.paused) { |
| 522 | var data = buffer.shift() |
| 523 | if(null === data) |
| 524 | return stream.emit('end') |
| 525 | else |
| 526 | stream.emit('data', data) |
| 527 | } |
| 528 | } |
| 529 | |
| 530 | stream.queue = stream.push = function (data) { |
| 531 | // console.error(ended) |