We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ac1b516 commit 0d77b79Copy full SHA for 0d77b79
Tests/RxSwiftTests/Anomalies.swift
@@ -184,6 +184,7 @@ extension AnomaliesTest {
184
observer.on(.next(()))
185
return Disposables.create()
186
}
187
+ .share(replay: 1)
188
189
let triggerRange = 0..<100
190
@@ -194,16 +195,14 @@ extension AnomaliesTest {
194
195
.observe(on: concurrentScheduler)
196
.flatMap { _ in
197
sharedSource
- .take(1)
198
199
+ .take(1)
200
})
201
202
_ = multipleSubscriptions.subscribe(onCompleted: {
203
exp.fulfill()
204
205
206
-
207
- wait(for: [exp], timeout: 5)
+ wait(for: [exp], timeout: 1)
208
209
0 commit comments