(pipe)
| 201 | |
| 202 | async _pipe(chunk) { |
| 203 | const write = function(pipe) { |
| 204 | return new Promise(resolve => { |
| 205 | pipe.write(chunk.toBuffer(), () => { |
| 206 | resolve(); |
| 207 | }); |
| 208 | }); |
| 209 | }; |
| 210 | await Promise.all(this.pipes.map(write)); |
| 211 | }, |
| 212 | _writeToBuffers(chunk) { |