mirror of
https://github.com/ReactiveX/RxSwift.git
synced 2024-10-05 22:47:15 +03:00
Add test
This commit is contained in:
parent
c3657fd33f
commit
a88841432d
@ -813,6 +813,23 @@ extension DriverTest {
|
||||
XCTAssertEqual(results, [1, -1])
|
||||
}
|
||||
|
||||
func testAsDriver_throttle2() {
|
||||
let hotObservable = BackgroundThreadPrimitiveHotObservable<Int>()
|
||||
let driver = hotObservable.asDriver(onErrorJustReturn: -1).throttle(0.5, latest: false)
|
||||
|
||||
let results = subscribeTwiceOnBackgroundSchedulerAndOnlyOneSubscription(driver) {
|
||||
XCTAssertTrue(hotObservable.subscriptions == [SubscribedToHotObservable])
|
||||
|
||||
hotObservable.on(.next(1))
|
||||
hotObservable.on(.next(2))
|
||||
hotObservable.on(.error(testError))
|
||||
|
||||
XCTAssertTrue(hotObservable.subscriptions == [UnsunscribedFromHotObservable])
|
||||
}
|
||||
|
||||
XCTAssertEqual(results, [1])
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
// MARK: scan
|
||||
|
Loading…
Reference in New Issue
Block a user