MCPcopy Create free account
hub / github.com/nodejs/node / pipeline

Function pipeline

deps/undici/undici.js:18131–18139  ·  view source on GitHub ↗
(opts, handler)

Source from the content-addressed store, hash-verified

18129 }
18130 };
18131 function pipeline(opts, handler) {
18132 try {
18133 const pipelineHandler = new PipelineHandler(opts, handler);
18134 this.dispatch({ ...opts, body: pipelineHandler.req }, pipelineHandler);
18135 return pipelineHandler.ret;
18136 } catch (err) {
18137 return new PassThrough().destroy(err);
18138 }
18139 }
18140 __name(pipeline, "pipeline");
18141 module2.exports = pipeline;
18142 }

Callers 15

writeStreamFunction · 0.70
onResponseStartFunction · 0.70
#connectMethod · 0.70
runFunction · 0.50
runFunction · 0.50
runFunction · 0.50
runFunction · 0.50
runFunction · 0.50
runClassicFunction · 0.50
testsFunction · 0.50

Calls 2

dispatchMethod · 0.65
destroyMethod · 0.45

Tested by

no test coverage detected