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