mirror of
https://github.com/ReactiveX/RxSwift.git
synced 2024-10-05 14:37:29 +03:00
Added Completable.zip tests
This commit is contained in:
parent
fb5da0f41a
commit
64cd783928
@ -147,6 +147,9 @@ final class CompletableTest_ : CompletableTest, RxTestCase {
|
||||
("test_merge_collection", CompletableTest.test_merge_collection),
|
||||
("test_merge_array", CompletableTest.test_merge_array),
|
||||
("test_merge_variadic", CompletableTest.test_merge_variadic),
|
||||
("test_zip_collection", CompletableTest.test_zip_collection),
|
||||
("test_zip_array", CompletableTest.test_zip_array),
|
||||
("test_zip_variadic", CompletableTest.test_zip_variadic),
|
||||
("testDefaultErrorHandler", CompletableTest.testDefaultErrorHandler),
|
||||
] }
|
||||
}
|
||||
|
@ -533,6 +533,42 @@ extension CompletableTest {
|
||||
.completed(200)
|
||||
])
|
||||
}
|
||||
|
||||
func test_zip_collection() {
|
||||
let scheduler = TestScheduler(initialClock: 0)
|
||||
|
||||
let res = scheduler.start {
|
||||
(Completable.zip(AnyCollection([Completable.empty(), Completable.empty()])) as Completable).asObservable()
|
||||
}
|
||||
|
||||
XCTAssertEqual(res.events, [
|
||||
.completed(200)
|
||||
])
|
||||
}
|
||||
|
||||
func test_zip_array() {
|
||||
let scheduler = TestScheduler(initialClock: 0)
|
||||
|
||||
let res = scheduler.start {
|
||||
(Completable.zip([Completable.empty(), Completable.empty()]) as Completable).asObservable()
|
||||
}
|
||||
|
||||
XCTAssertEqual(res.events, [
|
||||
.completed(200)
|
||||
])
|
||||
}
|
||||
|
||||
func test_zip_variadic() {
|
||||
let scheduler = TestScheduler(initialClock: 0)
|
||||
|
||||
let res = scheduler.start {
|
||||
(Completable.zip(Completable.empty(), Completable.empty()) as Completable).asObservable()
|
||||
}
|
||||
|
||||
XCTAssertEqual(res.events, [
|
||||
.completed(200)
|
||||
])
|
||||
}
|
||||
}
|
||||
|
||||
extension CompletableTest {
|
||||
|
Loading…
Reference in New Issue
Block a user