(arg: any, ctx: any)
| 3201 | |
| 3202 | const rawHandler = toRawHandler(fn) |
| 3203 | const handler = (arg: any, ctx: any) => { |
| 3204 | let current: any = rawHandler(arg, ctx) |
| 3205 | for (const combinator of combinators) { |
| 3206 | current = combinator(current, arg, ctx) |
| 3207 | } |
| 3208 | return toFinalStream(current) |
| 3209 | } |
| 3210 | |
| 3211 | return this.makeStreamCommand(id, options, errorDef)(handler) |
| 3212 | }, |
no outgoing calls