()
| 601 | signal, |
| 602 | |
| 603 | read() { |
| 604 | PromisePrototypeThen( |
| 605 | reader.read(), |
| 606 | (chunk) => { |
| 607 | if (chunk.done) { |
| 608 | // Value should always be undefined here. |
| 609 | readable.push(null); |
| 610 | } else { |
| 611 | readable.push(chunk.value); |
| 612 | } |
| 613 | }, |
| 614 | (error) => destroy(readable, error)); |
| 615 | }, |
| 616 | |
| 617 | destroy(error, callback) { |
| 618 | function done() { |