(opts, handler)
| 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 | } |
no test coverage detected