Skip to content

Commit f96a608

Browse files
freak4pcfreak4pc
committed
RxSwiftExt 5.0.0: RxSwift Tests
1 parent c82ff53 commit f96a608

29 files changed

+1181
-1177
lines changed

‎Tests/RxSwift/BufferWithTriggerTests.swift

Lines changed: 33 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
//
22
// BufferWithTriggerTests.swift
3-
// RxSwiftExt-iOS
3+
// RxSwiftExt
44
//
55
// Created by Patrick Maltagliati on 11/12/18.
6-
// Copyright © 2018 RxSwiftCommunity. All rights reserved.
6+
// Copyright © 2018 RxSwift Community. All rights reserved.
77
//
88

99
import XCTest
@@ -19,37 +19,38 @@ class BufferWithTriggerTests: XCTestCase {
1919
func testBuffersUntilBoundaryEmits() {
2020
let underlying = scheduler.createHotObservable(
2121
[
22-
next(150, 1),
23-
next(201, 2),
24-
next(230, 3),
25-
next(300, 4),
26-
next(350, 5),
27-
next(375, 6),
28-
next(400, 7),
29-
next(430, 8),
30-
completed(500)
22+
.next(150, 1),
23+
.next(201, 2),
24+
.next(230, 3),
25+
.next(300, 4),
26+
.next(350, 5),
27+
.next(375, 6),
28+
.next(400, 7),
29+
.next(430, 8),
30+
.completed(500)
3131
]
3232
)
3333

3434
let boundary = scheduler.createHotObservable(
3535
[
36-
next(201, ()),
37-
next(301, ()),
38-
next(401, ())
36+
.next(201, ()),
37+
.next(301, ()),
38+
.next(401, ())
3939
]
4040
)
4141

4242
let res = scheduler.start(disposed: 1000) {
4343
underlying.bufferWithTrigger(boundary.asObservable())
4444
}
4545

46-
let expected = [
47-
next(201, [2]),
48-
next(301, [3, 4]),
49-
next(401, [5, 6, 7]),
50-
next(500, [8]),
51-
completed(500)
52-
]
46+
let expected = Recorded.events([
47+
.next(201, [2]),
48+
.next(301, [3, 4]),
49+
.next(401, [5, 6, 7]),
50+
.next(500, [8]),
51+
.completed(500)
52+
])
53+
5354
XCTAssertEqual(res.events, expected)
5455

5556
XCTAssertEqual(underlying.subscriptions, [Subscription(200, 500)])
@@ -58,29 +59,29 @@ class BufferWithTriggerTests: XCTestCase {
5859
func testPausedError() {
5960
let underlying = scheduler.createHotObservable(
6061
[
61-
next(150, 1),
62-
next(210, 2),
63-
error(230, testError),
64-
completed(500)
62+
.next(150, 1),
63+
.next(210, 2),
64+
.error(230, testError),
65+
.completed(500)
6566
]
6667
)
6768

6869
let boundary = scheduler.createHotObservable(
6970
[
70-
next(201, ()),
71-
next(211, ())
71+
.next(201, ()),
72+
.next(211, ())
7273
]
7374
)
7475

7576
let res = scheduler.start(disposed: 1000) {
7677
underlying.bufferWithTrigger(boundary.asObservable())
7778
}
7879

79-
let expected = [
80-
next(201, []),
81-
next(211, [2]),
82-
error(230, testError)
83-
]
80+
let expected = Recorded.events([
81+
.next(201, []),
82+
.next(211, [2]),
83+
.error(230, testError)
84+
])
8485
XCTAssertEqual(res.events, expected)
8586

8687
XCTAssertEqual(underlying.subscriptions, [Subscription(200, 230)])

‎Tests/RxSwift/CountTests.swift

Lines changed: 46 additions & 46 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
//
22
// CountTests.swift
3-
// RxSwiftExt-iOS
3+
// RxSwiftExt
44
//
55
// Created by Fred on 06/11/2018.
6-
// Copyright © 2018 RxSwiftCommunity. All rights reserved.
6+
// Copyright © 2018 RxSwift Community. All rights reserved.
77
//
88

99
import XCTest
@@ -24,10 +24,10 @@ class CountTests: XCTestCase {
2424

2525
scheduler.start()
2626

27-
let correct = [
28-
next(0, 1),
29-
completed(0)
30-
]
27+
let correct = Recorded.events([
28+
.next(0, 1),
29+
.completed(0)
30+
])
3131

3232
XCTAssertEqual(observer.events, correct)
3333
}
@@ -43,10 +43,10 @@ class CountTests: XCTestCase {
4343

4444
scheduler.start()
4545

46-
let correct = [
47-
next(0, 1),
48-
completed(0)
49-
]
46+
let correct = Recorded.events([
47+
.next(0, 1),
48+
.completed(0)
49+
])
5050

5151
XCTAssertEqual(observer.events, correct)
5252
}
@@ -62,10 +62,10 @@ class CountTests: XCTestCase {
6262

6363
scheduler.start()
6464

65-
let correct = [
66-
next(0, 1),
67-
completed(0)
68-
]
65+
let correct = Recorded.events([
66+
.next(0, 1),
67+
.completed(0)
68+
])
6969

7070
XCTAssertEqual(observer.events, correct)
7171
}
@@ -81,10 +81,10 @@ class CountTests: XCTestCase {
8181

8282
scheduler.start()
8383

84-
let correct = [
85-
next(0, 2),
86-
completed(0)
87-
]
84+
let correct = Recorded.events([
85+
.next(0, 2),
86+
.completed(0)
87+
])
8888

8989
XCTAssertEqual(observer.events, correct)
9090
}
@@ -100,10 +100,10 @@ class CountTests: XCTestCase {
100100

101101
scheduler.start()
102102

103-
let correct = [
104-
next(0, 1),
105-
completed(0)
106-
]
103+
let correct = Recorded.events([
104+
.next(0, 1),
105+
.completed(0)
106+
])
107107

108108
XCTAssertEqual(observer.events, correct)
109109
}
@@ -119,10 +119,10 @@ class CountTests: XCTestCase {
119119

120120
scheduler.start()
121121

122-
let correct = [
123-
next(0, 0),
124-
completed(0)
125-
]
122+
let correct = Recorded.events([
123+
.next(0, 0),
124+
.completed(0)
125+
])
126126

127127
XCTAssertEqual(observer.events, correct)
128128
}
@@ -138,10 +138,10 @@ class CountTests: XCTestCase {
138138

139139
scheduler.start()
140140

141-
let correct = [
142-
next(0, 3),
143-
completed(0)
144-
]
141+
let correct = Recorded.events([
142+
.next(0, 3),
143+
.completed(0)
144+
])
145145

146146
XCTAssertEqual(observer.events, correct)
147147
}
@@ -157,10 +157,10 @@ class CountTests: XCTestCase {
157157

158158
scheduler.start()
159159

160-
let correct = [
161-
next(0, 0),
162-
completed(0)
163-
]
160+
let correct = Recorded.events([
161+
.next(0, 0),
162+
.completed(0)
163+
])
164164

165165
XCTAssertEqual(observer.events, correct)
166166
}
@@ -176,10 +176,10 @@ class CountTests: XCTestCase {
176176

177177
scheduler.start()
178178

179-
let correct = [
180-
next(0, 0),
181-
completed(0)
182-
]
179+
let correct = Recorded.events([
180+
.next(0, 0),
181+
.completed(0)
182+
])
183183

184184
XCTAssertEqual(observer.events, correct)
185185
}
@@ -195,10 +195,10 @@ class CountTests: XCTestCase {
195195

196196
scheduler.start()
197197

198-
let correct = [
199-
next(0, 2),
200-
completed(0)
201-
]
198+
let correct = Recorded.events([
199+
.next(0, 2),
200+
.completed(0)
201+
])
202202

203203
XCTAssertEqual(observer.events, correct)
204204
}
@@ -214,10 +214,10 @@ class CountTests: XCTestCase {
214214

215215
scheduler.start()
216216

217-
let correct = [
218-
next(0, 4),
219-
completed(0)
220-
]
217+
let correct = Recorded.events([
218+
.next(0, 4),
219+
.completed(0)
220+
])
221221

222222
XCTAssertEqual(observer.events, correct)
223223
}

0 commit comments

Comments
 (0)