Function
stream
(opts, factory, callback)
Source from the content-addressed store, hash-verified
| 10397 | util.destroy(res2, err); |
| 10398 | } |
| 10399 | this.callback = null; |
| 10400 | this.runInAsyncScope(callback2, null, err || null, { opaque: opaque2, trailers }); |
| 10401 | if (err) { |
| 10402 | abort(); |
| 10403 | } |
| 10404 | }); |
| 10405 | } |
| 10406 | res.on("drain", resume); |
| 10407 | this.res = res; |
| 10408 | const needDrain = res.writableNeedDrain !== void 0 ? res.writableNeedDrain : (_a = res._writableState) == null ? void 0 : _a.needDrain; |
| 10409 | return needDrain !== true; |
| 10410 | } |
| 10411 | onData(chunk) { |
| 10412 | const { res } = this; |
| 10413 | return res ? res.write(chunk) : true; |
| 10414 | } |
| 10415 | onComplete(trailers) { |
| 10416 | const { res } = this; |
| 10417 | removeSignal(this); |
| 10418 | if (!res) { |
| 10419 | return; |
Callers
nothing calls this directly
Tested by
no test coverage detected