(b)
| 126 | } |
| 127 | |
| 128 | function parserOnBody(b) { |
| 129 | const stream = this.incoming; |
| 130 | |
| 131 | // If the stream has already been removed, then drop it. |
| 132 | if (stream === null || stream[kSkipPendingData]) |
| 133 | return; |
| 134 | |
| 135 | // Pretend this was the result of a stream._read call. |
| 136 | if (!stream._dumped) { |
| 137 | const ret = stream.push(b); |
| 138 | if (!ret) |
| 139 | readStop(this.socket); |
| 140 | } |
| 141 | } |
| 142 | |
| 143 | function parserOnMessageComplete() { |
| 144 | const parser = this; |