Fix the test (it was broken)

ReactiveX · Feb 25, 2025 · 0d77b79 · 0d77b79
1 parent ac1b516
commit 0d77b79
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/Tests/RxSwiftTests/Anomalies.swift b/Tests/RxSwiftTests/Anomalies.swift
@@ -184,6 +184,7 @@ extension AnomaliesTest {
             observer.on(.next(()))
             return Disposables.create()
         }
+        .share(replay: 1)
 
         let triggerRange = 0..<100
 
@@ -194,16 +195,14 @@ extension AnomaliesTest {
                 .observe(on: concurrentScheduler)
                 .flatMap { _ in
                     sharedSource
-                        .take(1)
                 }
+                .take(1)
         })
-        .take(1)
 
         _ = multipleSubscriptions.subscribe(onCompleted: {
             exp.fulfill()
         })
 
-
-        wait(for: [exp], timeout: 5)
+        wait(for: [exp], timeout: 1)
     }
 }