()
| 47203 | } |
| 47204 | |
| 47205 | function drain() { |
| 47206 | while(buffer.length && !stream.paused) { |
| 47207 | var data = buffer.shift() |
| 47208 | if(null === data) |
| 47209 | return stream.emit('end') |
| 47210 | else |
| 47211 | stream.emit('data', data) |
| 47212 | } |
| 47213 | } |
| 47214 | |
| 47215 | stream.queue = stream.push = function (data) { |
| 47216 | // console.error(ended) |