From 3bb3c6cd51d24fe5636cdcf63670ea164f57aa63 Mon Sep 17 00:00:00 2001 From: Charles Lyding <19598772+clydin@users.noreply.github.com> Date: Thu, 8 Aug 2019 20:20:09 -0400 Subject: [PATCH] fix(@angular-devkit/core): ensure job input values are processed in order If schema validation happens to be asynchronous then the switchMap could cause loss of input values. --- .../core/src/experimental/jobs/simple-scheduler.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/angular_devkit/core/src/experimental/jobs/simple-scheduler.ts b/packages/angular_devkit/core/src/experimental/jobs/simple-scheduler.ts index afae90f2aadf..5bff342f66ed 100644 --- a/packages/angular_devkit/core/src/experimental/jobs/simple-scheduler.ts +++ b/packages/angular_devkit/core/src/experimental/jobs/simple-scheduler.ts @@ -306,7 +306,7 @@ export class SimpleScheduler< // Create the input channel by having a filter. const input = new Subject(); input.pipe( - switchMap(message => handler.pipe( + concatMap(message => handler.pipe( switchMap(handler => { if (handler === null) { throw new JobDoesNotExistException(name);