| 6760 | writeIterable(abort, body.stream(), client, request, socket, contentLength, header, expectsPayload); |
| 6761 | } else { |
| 6762 | writeBlob(abort, body, client, request, socket, contentLength, header, expectsPayload); |
| 6763 | } |
| 6764 | } else if (util.isStream(body)) { |
| 6765 | writeStream(abort, body, client, request, socket, contentLength, header, expectsPayload); |
| 6766 | } else if (util.isIterable(body)) { |
| 6767 | writeIterable(abort, body, client, request, socket, contentLength, header, expectsPayload); |
| 6768 | } else { |
| 6769 | assert(false); |
| 6770 | } |
| 6771 | return true; |
| 6772 | } |
| 6773 | function writeStream(abort, body, client, request, socket, contentLength, header, expectsPayload) { |
| 6774 | var _a, _b, _c; |
| 6775 | assert(contentLength !== 0 || client[kRunning] === 0, "stream body cannot be pipelined"); |
| 6776 | let finished = false; |