| 2986 | ) |
| 2987 | |
| 2988 | const theStreamHandler = (arg: Arg, ctx: Commander.CommandContextLocal2<Id, I18nKey, State>) => |
| 2989 | handler(arg, ctx).pipe( |
| 2990 | streamErrorReporter, |
| 2991 | Stream.provideService(CommandProgress, commandProgressService), |
| 2992 | Stream.provideServiceEffect(stateTag, currentState), |
| 2993 | Stream.provideServiceEffect(CommandContext, Effect.sync(() => makeContext_())) |
| 2994 | ) |
| 2995 | |
| 2996 | const waitId = options?.waitKey ? options.waitKey(id) : undefined |
| 2997 | const blockId = options?.blockKey ? options.blockKey(id) : undefined |