(s, o)
| 6379 | finishMaybe(s, o)) |
| 6380 | } |
| 6381 | function clearBuffer(s, o) { |
| 6382 | o.bufferProcessing = !0 |
| 6383 | var i = o.bufferedRequest |
| 6384 | if (s._writev && i && i.next) { |
| 6385 | var a = o.bufferedRequestCount, |
| 6386 | u = new Array(a), |
| 6387 | _ = o.corkedRequestsFree |
| 6388 | _.entry = i |
| 6389 | for (var w = 0, x = !0; i; ) ((u[w] = i), i.isBuf || (x = !1), (i = i.next), (w += 1)) |
| 6390 | ;((u.allBuffers = x), |
| 6391 | doWrite(s, o, !0, o.length, u, '', _.finish), |
| 6392 | o.pendingcb++, |
| 6393 | (o.lastBufferedRequest = null), |
| 6394 | _.next |
| 6395 | ? ((o.corkedRequestsFree = _.next), (_.next = null)) |
| 6396 | : (o.corkedRequestsFree = new CorkedRequest(o)), |
| 6397 | (o.bufferedRequestCount = 0)) |
| 6398 | } else { |
| 6399 | for (; i; ) { |
| 6400 | var C = i.chunk, |
| 6401 | j = i.encoding, |
| 6402 | L = i.callback |
| 6403 | if ( |
| 6404 | (doWrite(s, o, !1, o.objectMode ? 1 : C.length, C, j, L), |
| 6405 | (i = i.next), |
| 6406 | o.bufferedRequestCount--, |
| 6407 | o.writing) |
| 6408 | ) |
| 6409 | break |
| 6410 | } |
| 6411 | null === i && (o.lastBufferedRequest = null) |
| 6412 | } |
| 6413 | ;((o.bufferedRequest = i), (o.bufferProcessing = !1)) |
| 6414 | } |
| 6415 | function needFinish(s) { |
| 6416 | return ( |
| 6417 | s.ending && 0 === s.length && null === s.bufferedRequest && !s.finished && !s.writing |
no test coverage detected