(chunk)
| 52662 | channels.headers.publish({ request: this, response: { statusCode, headers, statusText } }); |
| 52663 | } |
| 52664 | try { |
| 52665 | return this[kHandler].onHeaders(statusCode, headers, resume2, statusText); |
| 52666 | } catch (err) { |
| 52667 | this.abort(err); |
| 52668 | } |
| 52669 | } |
| 52670 | onData(chunk) { |
| 52671 | assert2(!this.aborted); |
| 52672 | assert2(!this.completed); |
| 52673 | try { |
| 52674 | return this[kHandler].onData(chunk); |
| 52675 | } catch (err) { |
| 52676 | this.abort(err); |