()
| 6892 | } catch (err) { |
| 6893 | abort(err); |
| 6894 | } |
| 6895 | }); |
| 6896 | } |
| 6897 | function writeIterable(abort, body, client, request, socket, contentLength, header, expectsPayload) { |
| 6898 | return __async(this, null, function* () { |
| 6899 | assert(contentLength !== 0 || client[kRunning] === 0, "iterator body cannot be pipelined"); |
| 6900 | let callback = null; |
| 6901 | function onDrain() { |
| 6902 | if (callback) { |
| 6903 | const cb = callback; |
| 6904 | callback = null; |