Function rI5

package/cli.js:218–218

(q,K,_,z,Y,$,A,O)

`;if(Array.isArray(j))for(let D=0;D<j.length;D+=2){let f=j[D+0],G=j[D+1];if(Array.isArray(G))for(let Z=0;Z<G.length;Z++)W+=`${f}: ${G[Z]}\r
`;else W+=`${f}: ${G}\r
`}if(jI7.sendHeaders.hasSubscribers)jI7.sendHeaders.publish({request:K,headers:W,socket:X});if(!w||M===0)XI7(P,null,q,K,X,H,W,J);else if(K9.isBuffer(w))XI7(P,w,q,K,X,H,W,J);else if(K9.isBlobLike(w))if(typeof w.stream==="function")PI7(P,w.stream(),q,K,X,H,W,J);else oI5(P,w,q,K,X,H,W,J);else if(K9.isStream(w))rI5(P,w,q,K,X,H,W,J);else if(K9.isIterable(w))PI7(P,w,q,K,X,H,W,J);else z3(!1);return!0}function rI5(q,K,_,z,Y,$,A,O){z3($!==0||_[gZ]===0,"stream body cannot be pipelined");let w=!1,j=new V51({abort:q,socket:Y,request:z,contentLength:$,client:_,expectsPayload:O,header:A}),H=function(P){if(w)return;try{if(!j.write(P)&&this.pause)this.pause()}catch(W){K9.destroy(this,W)}},J=function(){if(w)return;if(K.resume)K.resume()},M=function(){if(queueMicrotask(()=>{K.removeListener("error",X)}),!w){let P=new WI7;queueMicrotask(()=>X(P))}},X=function(P){if(w)return;if(w=!0,z3(Y.destroyed||Y[re]&&_[gZ]<=1),Y.off("drain",J).off("error",X),K.removeListener("data",H).removeListener("end",X).removeListener("close",M),!P)try{j.end()}catch(W){P=W}if(j.destroy(P),P&&(P.code!=="UND_ERR_INFO"||P.message!=="reset"))K9.destroy(K,P);else K9.destroy(K)};if(K.on("data",H).on("end",X).on("error",X).on("close",M),K.resume)K.resume();if(Y.on("drain",J).on("error",X),K.errorEmitted??K.errored)setImmediate(()=>X(K.errored));else if(K.endEmitted??K.readableEnded)setImmediate(()=>X(null));if(K.closeEmitted??K.closed)setImmediate(M)}function XI7(q,K,_,z,Y,$,A,O){try{if(!K)if($===0)Y.write(`${A}content-length: 0\r
\r
`,"latin1");else z3($===null,"no body must not have content length"),Y.write(`${A}\r
`,"latin1");else if(K9.isBuffer(K)){if(z3($===K.byteLength,"buffer body must have content length"),Y.cork(),Y.write(`${A}content-length: ${$}\r