(cb)
| 2350 | } |
| 2351 | |
| 2352 | _final(cb) { |
| 2353 | if (this.pending) { |
| 2354 | this.once('ready', () => this._final(cb)); |
| 2355 | return; |
| 2356 | } |
| 2357 | debugStreamObj(this, 'shutting down writable on _final'); |
| 2358 | shutdownWritable.call(this, cb); |
| 2359 | |
| 2360 | if (this.session[kType] === NGHTTP2_SESSION_CLIENT && onClientStreamBodySentChannel.hasSubscribers) { |
| 2361 | onClientStreamBodySentChannel.publish({ stream: this }); |
| 2362 | } |
| 2363 | } |
| 2364 | |
| 2365 | _read(nread) { |
| 2366 | if (this.destroyed) { |
nothing calls this directly
no test coverage detected