TouchInstinct
/
RxSwift
311
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Removes `sampleLatest` unit tests.

This commit is contained in:
Krunoslav Zaher 2015-12-30 02:10:53 +01:00
parent 5db80857b9
commit a3e2765e3d
1 changed files with 0 additions and 218 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

218
Tests/RxSwiftTests/Tests/Observable+TimeTest.swift
View File

@ -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