fix(@angular-devkit/architect): one more fix for newest version of rxjs

vikerman · vikerman · commit 5ef084621493 · 2019-07-02T12:46:30.000-07:00
diff --git a/packages/angular_devkit/core/src/experimental/jobs/simple-scheduler.ts b/packages/angular_devkit/core/src/experimental/jobs/simple-scheduler.ts
@@ -509,7 +509,8 @@ export class SimpleScheduler<
       waitable,
 
       from(handler).pipe(
-        switchMap(handler => new Observable((subscriber: Observer<JobOutboundMessage<O>>) => {
+        switchMap(handler => new Observable<JobOutboundMessage<O>>(
+                      (subscriber: Observer<JobOutboundMessage<O>>) => {
           if (!handler) {
             throw new JobDoesNotExistException(name);
           }

Original file line number	Diff line number	Diff line change
`@@ -509,7 +509,8 @@ export class SimpleScheduler<`
`509`	`509`	`waitable,`
`510`	`510`
`511`	`511`	`from(handler).pipe(`
`512`		`- switchMap(handler => new Observable((subscriber: Observer<JobOutboundMessage<O>>) => {`
	`512`	`+ switchMap(handler => new Observable<JobOutboundMessage<O>>(`
	`513`	`+ (subscriber: Observer<JobOutboundMessage<O>>) => {`
`513`	`514`	`if (!handler) {`
`514`	`515`	`throw new JobDoesNotExistException(name);`
`515`	`516`	`}`