• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 // This file was automatically generated from coroutines-guide-reactive.md by Knit tool. Do not edit.
2 package kotlinx.coroutines.rx2.guide.test
3 
4 import kotlinx.coroutines.guide.test.*
5 import org.junit.Test
6 
7 class GuideReactiveTest : ReactiveTestBase() {
8 
9     @Test
testKotlinxCoroutinesRx2GuideBasic01null10     fun testKotlinxCoroutinesRx2GuideBasic01() {
11         test("KotlinxCoroutinesRx2GuideBasic01") { kotlinx.coroutines.rx2.guide.basic01.main() }.verifyLines(
12             "Elements:",
13             "Begin",
14             "1",
15             "2",
16             "3",
17             "Again:"
18         )
19     }
20 
21     @Test
testKotlinxCoroutinesRx2GuideBasic02null22     fun testKotlinxCoroutinesRx2GuideBasic02() {
23         test("KotlinxCoroutinesRx2GuideBasic02") { kotlinx.coroutines.rx2.guide.basic02.main() }.verifyLines(
24             "Elements:",
25             "Begin",
26             "1",
27             "2",
28             "3",
29             "Again:",
30             "Begin",
31             "1",
32             "2",
33             "3"
34         )
35     }
36 
37     @Test
testKotlinxCoroutinesRx2GuideBasic03null38     fun testKotlinxCoroutinesRx2GuideBasic03() {
39         test("KotlinxCoroutinesRx2GuideBasic03") { kotlinx.coroutines.rx2.guide.basic03.main() }.verifyLines(
40             "OnSubscribe",
41             "1",
42             "2",
43             "3",
44             "Finally"
45         )
46     }
47 
48     @Test
testKotlinxCoroutinesRx2GuideBasic04null49     fun testKotlinxCoroutinesRx2GuideBasic04() {
50         test("KotlinxCoroutinesRx2GuideBasic04") { kotlinx.coroutines.rx2.guide.basic04.main() }.verifyLines(
51             "OnSubscribe",
52             "1",
53             "2",
54             "3",
55             "OnComplete",
56             "Finally",
57             "4",
58             "5"
59         )
60     }
61 
62     @Test
testKotlinxCoroutinesRx2GuideBasic05null63     fun testKotlinxCoroutinesRx2GuideBasic05() {
64         test("KotlinxCoroutinesRx2GuideBasic05") { kotlinx.coroutines.rx2.guide.basic05.main() }.verifyLines(
65             "Sent 1",
66             "Processed 1",
67             "Sent 2",
68             "Processed 2",
69             "Sent 3",
70             "Processed 3",
71             "Complete"
72         )
73     }
74 
75     @Test
testKotlinxCoroutinesRx2GuideBasic06null76     fun testKotlinxCoroutinesRx2GuideBasic06() {
77         test("KotlinxCoroutinesRx2GuideBasic06") { kotlinx.coroutines.rx2.guide.basic06.main() }.verifyLines(
78             "two",
79             "three",
80             "four"
81         )
82     }
83 
84     @Test
testKotlinxCoroutinesRx2GuideBasic07null85     fun testKotlinxCoroutinesRx2GuideBasic07() {
86         test("KotlinxCoroutinesRx2GuideBasic07") { kotlinx.coroutines.rx2.guide.basic07.main() }.verifyLines(
87             "two",
88             "three",
89             "four"
90         )
91     }
92 
93     @Test
testKotlinxCoroutinesRx2GuideBasic08null94     fun testKotlinxCoroutinesRx2GuideBasic08() {
95         test("KotlinxCoroutinesRx2GuideBasic08") { kotlinx.coroutines.rx2.guide.basic08.main() }.verifyLines(
96             "four"
97         )
98     }
99 
100     @Test
testKotlinxCoroutinesRx2GuideBasic09null101     fun testKotlinxCoroutinesRx2GuideBasic09() {
102         test("KotlinxCoroutinesRx2GuideBasic09") { kotlinx.coroutines.rx2.guide.basic09.main() }.verifyLines(
103             "four"
104         )
105     }
106 
107     @Test
testKotlinxCoroutinesRx2GuideOperators01null108     fun testKotlinxCoroutinesRx2GuideOperators01() {
109         test("KotlinxCoroutinesRx2GuideOperators01") { kotlinx.coroutines.rx2.guide.operators01.main() }.verifyLines(
110             "1",
111             "2",
112             "3",
113             "4",
114             "5"
115         )
116     }
117 
118     @Test
testKotlinxCoroutinesRx2GuideOperators02null119     fun testKotlinxCoroutinesRx2GuideOperators02() {
120         test("KotlinxCoroutinesRx2GuideOperators02") { kotlinx.coroutines.rx2.guide.operators02.main() }.verifyLines(
121             "2 is even",
122             "4 is even"
123         )
124     }
125 
126     @Test
testKotlinxCoroutinesRx2GuideOperators03null127     fun testKotlinxCoroutinesRx2GuideOperators03() {
128         test("KotlinxCoroutinesRx2GuideOperators03") { kotlinx.coroutines.rx2.guide.operators03.main() }.verifyLines(
129             "1",
130             "2"
131         )
132     }
133 
134     @Test
testKotlinxCoroutinesRx2GuideOperators04null135     fun testKotlinxCoroutinesRx2GuideOperators04() {
136         test("KotlinxCoroutinesRx2GuideOperators04") { kotlinx.coroutines.rx2.guide.operators04.main() }.verifyLines(
137             "1",
138             "2",
139             "11",
140             "3",
141             "4",
142             "12",
143             "13"
144         )
145     }
146 
147     @Test
testKotlinxCoroutinesRx2GuideContext01null148     fun testKotlinxCoroutinesRx2GuideContext01() {
149         test("KotlinxCoroutinesRx2GuideContext01") { kotlinx.coroutines.rx2.guide.context01.main() }.verifyLinesFlexibleThread(
150             "1 on thread RxComputationThreadPool-1",
151             "2 on thread RxComputationThreadPool-1",
152             "3 on thread RxComputationThreadPool-1"
153         )
154     }
155 
156     @Test
testKotlinxCoroutinesRx2GuideContext02null157     fun testKotlinxCoroutinesRx2GuideContext02() {
158         test("KotlinxCoroutinesRx2GuideContext02") { kotlinx.coroutines.rx2.guide.context02.main() }.verifyLinesStart(
159             "1 on thread ForkJoinPool.commonPool-worker-1",
160             "2 on thread ForkJoinPool.commonPool-worker-1",
161             "3 on thread ForkJoinPool.commonPool-worker-1"
162         )
163     }
164 
165     @Test
testKotlinxCoroutinesRx2GuideContext03null166     fun testKotlinxCoroutinesRx2GuideContext03() {
167         test("KotlinxCoroutinesRx2GuideContext03") { kotlinx.coroutines.rx2.guide.context03.main() }.verifyLinesFlexibleThread(
168             "1 on thread RxComputationThreadPool-1",
169             "2 on thread RxComputationThreadPool-1",
170             "3 on thread RxComputationThreadPool-1"
171         )
172     }
173 
174     @Test
testKotlinxCoroutinesRx2GuideContext04null175     fun testKotlinxCoroutinesRx2GuideContext04() {
176         test("KotlinxCoroutinesRx2GuideContext04") { kotlinx.coroutines.rx2.guide.context04.main() }.verifyLinesStart(
177             "1 on thread main",
178             "2 on thread main",
179             "3 on thread main"
180         )
181     }
182 
183     @Test
testKotlinxCoroutinesRx2GuideContext05null184     fun testKotlinxCoroutinesRx2GuideContext05() {
185         test("KotlinxCoroutinesRx2GuideContext05") { kotlinx.coroutines.rx2.guide.context05.main() }.verifyLinesStart(
186             "1 on thread RxComputationThreadPool-1",
187             "2 on thread RxComputationThreadPool-1",
188             "3 on thread RxComputationThreadPool-1"
189         )
190     }
191 }
192