Skip to content

Commit 172ebae

Browse files
FroussiosFroussios
committed
Added runnable examples: Chapter 2
1 parent 7ca227c commit 172ebae

29 files changed

+586
-190
lines changed

‎tests/java/itrx/chapter2/aggregation/CollectTest.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@ public void example() {
1919
() -> new ArrayList<Integer>(),
2020
(acc, value) -> acc.add(value))
2121
.subscribe(v -> System.out.println(v));
22+
23+
// [10, 11, 12, 13, 14]
2224
}
2325

2426
@Test

‎tests/java/itrx/chapter2/aggregation/CountTest.java‎

Lines changed: 17 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -39,12 +39,12 @@ public void example() {
3939
.count()
4040
.subscribe(new PrintSubscriber("Count"));
4141

42-
// Values: 0
43-
// Values: 1
44-
// Values: 2
45-
// Values: Completed
46-
// Count: 3
47-
// Count: Completed
42+
// Values: 0
43+
// Values: 1
44+
// Values: 2
45+
// Values: Completed
46+
// Count: 3
47+
// Count: Completed
4848
}
4949

5050
public void exampleCountLong() {
@@ -56,14 +56,19 @@ public void exampleCountLong() {
5656
.countLong()
5757
.subscribe(new PrintSubscriber("Count"));
5858

59-
// Values: 0
60-
// Values: 1
61-
// Values: 2
62-
// Values: Completed
63-
// Count: 3
64-
// Count: Completed
59+
// Values: 0
60+
// Values: 1
61+
// Values: 2
62+
// Values: Completed
63+
// Count: 3
64+
// Count: Completed
6565
}
6666

67+
68+
//
69+
// Tests
70+
//
71+
6772
@Test
6873
public void test() {
6974
TestSubscriber<Integer> testerSource = new TestSubscriber<>();

‎tests/java/itrx/chapter2/aggregation/FirstTest.java‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,11 @@ public void exampleFirstOrDefaultWithPredicate() {
7171

7272
// -1
7373
}
74+
75+
76+
//
77+
// Tests
78+
//
7479

7580
@Test
7681
public void testFirst() {

‎tests/java/itrx/chapter2/aggregation/GroupByTest.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,9 @@ public void exampleGroupBy() {
2525
)
2626
.subscribe(v -> System.out.println(v));
2727

28-
// s: sixth
29-
// t: third
30-
// f: fifth
28+
// s: sixth
29+
// t: third
30+
// f: fifth
3131
}
3232

3333

‎tests/java/itrx/chapter2/aggregation/LastTest.java‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,11 @@ public void exampleLastOrDefaultWithPredicate() {
6868

6969
// -1
7070
}
71+
72+
73+
//
74+
// Tests
75+
//
7176

7277
@Test
7378
public void testLast() {

‎tests/java/itrx/chapter2/aggregation/ReduceTest.java‎

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -40,10 +40,10 @@ public void example() {
4040
.reduce((i1,i2) -> (i1>i2) ? i2 : i1)
4141
.subscribe(new PrintSubscriber("Min"));
4242

43-
// Sum: 10
44-
// Sum: Completed
45-
// Min: 0
46-
// Min: Completed
43+
// Sum: 10
44+
// Sum: Completed
45+
// Min: 0
46+
// Min: Completed
4747
}
4848

4949
public void exampleWithAccumulator() {
@@ -52,11 +52,16 @@ public void exampleWithAccumulator() {
5252
values
5353
.reduce(0, (acc,next) -> acc + 1)
5454
.subscribe(new PrintSubscriber("Count"));
55-
56-
// Count: 3
57-
// Count: Completed
55+
56+
// Count: 3
57+
// Count: Completed
5858
}
5959

60+
61+
//
62+
// Tests
63+
//
64+
6065
@Test
6166
public void test() {
6267
TestSubscriber<Integer> testerSum = new TestSubscriber<>();

‎tests/java/itrx/chapter2/aggregation/ScanTest.java‎

Lines changed: 19 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -39,12 +39,12 @@ public void exampleRunningSum() {
3939
.scan((i1,i2) -> i1+i2)
4040
.subscribe(new PrintSubscriber("Sum"));
4141

42-
// Sum: 0
43-
// Sum: 1
44-
// Sum: 3
45-
// Sum: 6
46-
// Sum: 10
47-
// Sum: Completed
42+
// Sum: 0
43+
// Sum: 1
44+
// Sum: 3
45+
// Sum: 6
46+
// Sum: 10
47+
// Sum: Completed
4848
}
4949

5050
public void exampleRunningMin() {
@@ -63,16 +63,21 @@ public void exampleRunningMin() {
6363
values.onNext(4);
6464
values.onCompleted();
6565

66-
// Values: 2
67-
// Min: 2
68-
// Values: 3
69-
// Values: 1
70-
// Min: 1
71-
// Values: 4
72-
// Values: Completed
73-
// Min: Completed
66+
// Values: 2
67+
// Min: 2
68+
// Values: 3
69+
// Values: 1
70+
// Min: 1
71+
// Values: 4
72+
// Values: Completed
73+
// Min: Completed
7474
}
7575

76+
77+
//
78+
// Tests
79+
//
80+
7681
@Test
7782
public void testRunningSum() {
7883
TestSubscriber<Integer> tester = new TestSubscriber<>();

‎tests/java/itrx/chapter2/aggregation/SingleTest.java‎

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,8 @@ public void exampleSingle() {
4545
.single(v -> v == 5L) // Never emits
4646
.subscribe(new PrintSubscriber("Single2"));
4747

48-
// Single1: 5
49-
// Single1: Completed
48+
// Single1: 5
49+
// Single1: Completed
5050
}
5151

5252
public void exampleSingleOrDefault() {
@@ -56,10 +56,15 @@ public void exampleSingleOrDefault() {
5656
.singleOrDefault(-1)
5757
.subscribe(new PrintSubscriber("SingleOrDefault"));
5858

59-
// SingleOrDefault: -1
60-
// SingleOrDefault: Completed
59+
// SingleOrDefault: -1
60+
// SingleOrDefault: Completed
6161
}
6262

63+
64+
//
65+
// Tests
66+
//
67+
6368
@Test
6469
public void testSingle() {
6570
TestSubscriber<Long> tester1 = new TestSubscriber<>();

‎tests/java/itrx/chapter2/aggregation/ToCollectionTest.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ public void exampleCustom() {
2323
})
2424
.subscribe(v -> System.out.println(v));
2525

26-
// [10, 11, 12, 13, 14]
26+
// [10, 11, 12, 13, 14]
2727
}
2828

2929
public void exampleToList() {
@@ -33,7 +33,7 @@ public void exampleToList() {
3333
.toList()
3434
.subscribe(v -> System.out.println(v));
3535

36-
// [10, 11, 12, 13, 14]
36+
// [10, 11, 12, 13, 14]
3737
}
3838

3939
public void exampleToSortedList() {
@@ -43,7 +43,7 @@ public void exampleToSortedList() {
4343
.toSortedList((i1,i2) -> i2 - i1)
4444
.subscribe(v -> System.out.println(v));
4545

46-
// [14, 13, 12, 11, 10]
46+
// [14, 13, 12, 11, 10]
4747
}
4848

4949

‎tests/java/itrx/chapter2/aggregation/ToMapTest.java‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -66,8 +66,8 @@ public void exampleToMap() {
6666
.toMap(person -> person.name)
6767
.subscribe(new PrintSubscriber("toMap"));
6868

69-
// toMap: {Saul=Person@7cd84586, Nick=Person@30dae81, Will=Person@1b2c6ec2}
70-
// toMap: Completed
69+
// toMap: {Saul=Person@7cd84586, Nick=Person@30dae81, Will=Person@1b2c6ec2}
70+
// toMap: Completed
7171
}
7272

7373
public void exampleToMapWithSelector() {
@@ -83,8 +83,8 @@ public void exampleToMapWithSelector() {
8383
person -> person.age)
8484
.subscribe(new PrintSubscriber("toMap"));
8585

86-
// toMap: {Saul=35, Nick=40, Will=25}
87-
// toMap: Completed
86+
// toMap: {Saul=35, Nick=40, Will=25}
87+
// toMap: Completed
8888
}
8989

9090
public void exampleToMapWithCustomContainer() {
@@ -101,8 +101,8 @@ public void exampleToMapWithCustomContainer() {
101101
() -> new HashMap<String, Integer>())
102102
.subscribe(new PrintSubscriber("toMap"));
103103

104-
// toMap: {Saul=35, Nick=40, Will=25}
105-
// toMap: Completed
104+
// toMap: {Saul=35, Nick=40, Will=25}
105+
// toMap: Completed
106106
}
107107

108108
public void exampleToMultimap() {
@@ -118,8 +118,8 @@ public void exampleToMultimap() {
118118
person -> person.name)
119119
.subscribe(new PrintSubscriber("toMap"));
120120

121-
// toMap: {35=[Will, Saul], 40=[Nick]}
122-
// toMap: Completed
121+
// toMap: {35=[Will, Saul], 40=[Nick]}
122+
// toMap: Completed
123123
}
124124

125125
public void exampleToMultimapWithCustomContainers() {
@@ -137,8 +137,8 @@ public void exampleToMultimapWithCustomContainers() {
137137
(key) -> new ArrayList<>())
138138
.subscribe(new PrintSubscriber("toMap"));
139139

140-
// toMap: {35=[Will, Saul], 40=[Nick]}
141-
// toMap: Completed
140+
// toMap: {35=[Will, Saul], 40=[Nick]}
141+
// toMap: Completed
142142
}
143143

144144

0 commit comments

Comments
 (0)