()
| 6077 | this.timeoutType = type; |
| 6078 | } |
| 6079 | resume() { |
| 6080 | if (this.socket.destroyed || !this.paused) { |
| 6081 | return; |
| 6082 | } |
| 6083 | assert(this.ptr != null); |
| 6084 | assert(currentParser == null); |
| 6085 | this.llhttp.llhttp_resume(this.ptr); |
| 6086 | assert(this.timeoutType === TIMEOUT_BODY); |
| 6087 | if (this.timeout) { |
| 6088 | if (this.timeout.refresh) { |
| 6089 | this.timeout.refresh(); |
| 6090 | } |
| 6091 | } |
| 6092 | this.paused = false; |
| 6093 | this.execute(this.socket.read() || EMPTY_BUF); |
| 6094 | this.readMore(); |
| 6095 | } |
| 6096 | readMore() { |
| 6097 | while (!this.paused && this.ptr) { |
| 6098 | const chunk = this.socket.read(); |
no test coverage detected