()
| 6192 | this.ptr = null; |
| 6193 | this.timeout && timers.clearTimeout(this.timeout); |
| 6194 | this.timeout = null; |
| 6195 | this.timeoutValue = null; |
| 6196 | this.timeoutType = null; |
| 6197 | this.paused = false; |
| 6198 | } |
| 6199 | onStatus(buf) { |
| 6200 | this.statusText = buf.toString(); |
| 6201 | } |
| 6202 | onMessageBegin() { |
| 6203 | const { socket, client } = this; |
| 6204 | if (socket.destroyed) { |
| 6205 | return -1; |
| 6206 | } |
| 6207 | if (client[kRunning] === 0) { |
| 6208 | util.destroy(socket, new SocketError("bad response", util.getSocketInfo(socket))); |
| 6209 | return -1; |
| 6210 | } |
| 6211 | const request = client[kQueue][client[kRunningIdx]]; |
no test coverage detected