diff --git a/Tests/RxSwiftTests/Tests/Observable+TimeTest.swift b/Tests/RxSwiftTests/Tests/Observable+TimeTest.swift index 8ab04534..6cf2113d 100644 --- a/Tests/RxSwiftTests/Tests/Observable+TimeTest.swift +++ b/Tests/RxSwiftTests/Tests/Observable+TimeTest.swift @@ -488,224 +488,6 @@ extension ObservableTimeTest { ]) } - func testSampleLatest_Sampler_SamplerThrows() { - let scheduler = TestScheduler(initialClock: 0) - - let xs = scheduler.createHotObservable([ - next(150, 1), - next(220, 2), - next(240, 3), - next(290, 4), - next(300, 5), - next(310, 6), - completed(400) - ]) - - let ys = scheduler.createHotObservable([ - next(150, ""), - next(210, "bar"), - next(250, "foo"), - next(260, "qux"), - error(320, testError) - ]) - - let res = scheduler.start { - xs.sampleLatest(ys) - } - - let correct = [ - next(250, 3), - next(260, 3), - error(320, testError) - ] - - XCTAssertEqual(res.events, correct) - - XCTAssertEqual(xs.subscriptions, [ - Subscription(200, 320) - ]) - - XCTAssertEqual(ys.subscriptions, [ - Subscription(200, 320) - ]) - } - - func testSampleLatest_Sampler_Simple1() { - let scheduler = TestScheduler(initialClock: 0) - - let xs = scheduler.createHotObservable([ - next(150, 1), - next(220, 2), - next(240, 3), - next(290, 4), - next(300, 5), - next(310, 6), - completed(400) - ]) - - let ys = scheduler.createHotObservable([ - next(150, ""), - next(210, "bar"), - next(250, "foo"), - next(260, "qux"), - next(320, "baz"), - completed(500) - ]) - - let res = scheduler.start { - xs.sampleLatest(ys) - } - - let correct = [ - next(250, 3), - next(260, 3), - next(320, 6), - next(500, 6), - completed(500) - ] - - XCTAssertEqual(res.events, correct) - - XCTAssertEqual(xs.subscriptions, [ - Subscription(200, 400) - ]) - - XCTAssertEqual(ys.subscriptions, [ - Subscription(200, 500) - ]) - } - - func testSampleLatest_Sampler_Simple2() { - let scheduler = TestScheduler(initialClock: 0) - - let xs = scheduler.createHotObservable([ - next(150, 1), - next(220, 2), - next(240, 3), - next(290, 4), - next(300, 5), - next(310, 6), - next(360, 7), - completed(400) - ]) - - let ys = scheduler.createHotObservable([ - next(150, ""), - next(210, "bar"), - next(250, "foo"), - next(260, "qux"), - next(320, "baz"), - completed(500) - ]) - - let res = scheduler.start { - xs.sampleLatest(ys) - } - - let correct = [ - next(250, 3), - next(260, 3), - next(320, 6), - next(500, 7), - completed(500) - ] - - XCTAssertEqual(res.events, correct) - - XCTAssertEqual(xs.subscriptions, [ - Subscription(200, 400) - ]) - - XCTAssertEqual(ys.subscriptions, [ - Subscription(200, 500) - ]) - } - - func testSampleLatest_Sampler_Simple3() { - let scheduler = TestScheduler(initialClock: 0) - - let xs = scheduler.createHotObservable([ - next(150, 1), - next(220, 2), - next(240, 3), - next(290, 4), - completed(300) - ]) - - let ys = scheduler.createHotObservable([ - next(150, ""), - next(210, "bar"), - next(250, "foo"), - next(260, "qux"), - next(320, "baz"), - completed(500) - ]) - - let res = scheduler.start { - xs.sampleLatest(ys) - } - - let correct = [ - next(250, 3), - next(260, 3), - next(320, 4), - completed(320) - ] - - XCTAssertEqual(res.events, correct) - - XCTAssertEqual(xs.subscriptions, [ - Subscription(200, 300) - ]) - - XCTAssertEqual(ys.subscriptions, [ - Subscription(200, 320) - ]) - } - - func testSampleLatest_Sampler_SourceThrows() { - let scheduler = TestScheduler(initialClock: 0) - - let xs = scheduler.createHotObservable([ - next(150, 1), - next(220, 2), - next(240, 3), - next(290, 4), - next(300, 5), - next(310, 6), - error(320, testError) - ]) - - let ys = scheduler.createHotObservable([ - next(150, ""), - next(210, "bar"), - next(250, "foo"), - next(260, "qux"), - next(300, "baz"), - completed(400) - ]) - - let res = scheduler.start { - xs.sampleLatest(ys) - } - - let correct = [ - next(250, 3), - next(260, 3), - next(300, 5), - error(320, testError) - ] - - XCTAssertEqual(res.events, correct) - - XCTAssertEqual(xs.subscriptions, [ - Subscription(200, 320) - ]) - - XCTAssertEqual(ys.subscriptions, [ - Subscription(200, 320) - ]) - } } // MARK: Interval