fix(timeout): defer error creation until timeout occurs (#5497)

- closes #5491
ReactiveX · Jul 5, 2020 · 3be9840 · 3be9840
1 parent 144b626
commit 3be9840
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/internal/operators/timeout.ts b/src/internal/operators/timeout.ts
@@ -3,6 +3,9 @@ import { TimeoutError } from '../util/TimeoutError';
 import { MonoTypeOperatorFunction, SchedulerLike } from '../types';
 import { timeoutWith } from './timeoutWith';
 import { throwError } from '../observable/throwError';
+import { defer } from '../observable/defer';
+
+function timeoutErrFactory() { return throwError(new TimeoutError()); }
 
 /**
  *
@@ -83,5 +86,5 @@ import { throwError } from '../observable/throwError';
  */
 export function timeout<T>(due: number | Date,
                            scheduler: SchedulerLike = async): MonoTypeOperatorFunction<T> {
-  return timeoutWith(due, throwError(new TimeoutError()), scheduler);
+  return timeoutWith(due, defer(timeoutErrFactory), scheduler);
 }