Function newHandler

packages/angular_devkit/architect/src/jobs/strategy.ts:50–58

(argument: A, context: JobHandlerContext<A, I, O>)

  return (handler, options) => {
    const newHandler = (argument: A, context: JobHandlerContext<A, I, O>) => {
      const previous = latest;
      latest = concat(
        previous.pipe(ignoreElements()),
        new Observable<JobOutboundMessage<O>>((o) => handler(argument, context).subscribe(o)),
      ).pipe(shareReplay(0));

      return latest;
    };

    return Object.assign(newHandler, {
      jobDescription: Object.assign({}, handler.jobDescription, options),