fix(race): ignore sources after first complete/error

Closes ReactiveX#4808
cartant · May 25, 2019 · 9252102 · 9252102
1 parent af8037a
commit 9252102
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/internal/observable/race.ts b/src/internal/observable/race.ts
@@ -137,4 +137,14 @@ export class RaceSubscriber<T> extends OuterSubscriber<T, T> {
 
     this.destination.next(innerValue);
   }
+
+  notifyComplete(innerSub: InnerSubscriber<T, T>): void {
+    this.hasFirst = true;
+    super.notifyComplete(innerSub);
+  }
+
+  notifyError(error: any, innerSub: InnerSubscriber<T, T>): void {
+    this.hasFirst = true;
+    super.notifyError(error, innerSub);
+  }
 }