Skip to content

Commit 8b96094

Browse files
committed
Add more stream examples
1 parent 30cf084 commit 8b96094

File tree

3 files changed

+75
-20
lines changed

3 files changed

+75
-20
lines changed

src/com/winterbe/java8/Streams5.java

Lines changed: 15 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.winterbe.java8;
22

3-
import java.util.ArrayList;
3+
import java.util.Arrays;
44
import java.util.List;
55
import java.util.stream.Stream;
66

@@ -12,20 +12,16 @@
1212
public class Streams5 {
1313

1414
public static void main(String[] args) {
15-
List<String> stringCollection = new ArrayList<>();
16-
stringCollection.add("ddd2");
17-
stringCollection.add("aaa2");
18-
stringCollection.add("bbb1");
19-
stringCollection.add("bbb3");
20-
stringCollection.add("ccc");
15+
List<String> strings =
16+
Arrays.asList("d2", "a2", "b1", "b3", "c");
2117

22-
// test1(stringCollection);
23-
// test2(stringCollection);
24-
// test3(stringCollection);
25-
// test4(stringCollection);
26-
test5(stringCollection);
27-
// test6(stringCollection);
28-
// test7(stringCollection);
18+
// test1(strings);
19+
// test2(strings);
20+
// test3(strings);
21+
// test4(strings);
22+
// test5(strings);
23+
test6(strings);
24+
// test7(strings);
2925
}
3026

3127
// stream has already been operated upon or closed
@@ -42,15 +38,14 @@ private static void test7(List<String> stringCollection) {
4238
private static void test6(List<String> stringCollection) {
4339
stringCollection
4440
.stream()
45-
.filter(s -> {
46-
System.out.println("filter: " + s);
47-
return s.startsWith("a");
48-
})
4941
.map(s -> {
50-
System.out.println("map: " + s);
42+
System.out.println("map: " + s);
5143
return s.toUpperCase();
5244
})
53-
.anyMatch(s -> s.startsWith("A"));
45+
.anyMatch(s -> {
46+
System.out.println("anyMatch: " + s);
47+
return s.startsWith("A");
48+
});
5449
}
5550

5651
private static void test5(List<String> stringCollection) {

src/com/winterbe/java8/Streams8.java

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
package com.winterbe.java8;
2+
3+
import java.util.Arrays;
4+
import java.util.stream.IntStream;
5+
import java.util.stream.Stream;
6+
7+
/**
8+
* @author Benjamin Winterberg
9+
*/
10+
public class Streams8 {
11+
12+
public static void main(String[] args) {
13+
Arrays.asList("a1", "a2", "a3")
14+
.stream()
15+
.findFirst()
16+
.ifPresent(System.out::println);
17+
18+
Stream.of("a1", "a2", "a3")
19+
.map(s -> s.substring(1))
20+
.mapToInt(Integer::parseInt)
21+
.max()
22+
.ifPresent(System.out::println);
23+
24+
IntStream.range(1, 4)
25+
.mapToObj(i -> "a" + i)
26+
.forEach(System.out::println);
27+
28+
Arrays.stream(new int[] {1, 2, 3})
29+
.map(n -> 2 * n + 1)
30+
.average()
31+
.ifPresent(System.out::println);
32+
33+
Stream.of(1.0, 2.0, 3.0)
34+
.mapToInt(Double::intValue)
35+
.mapToObj(i -> "a" + i)
36+
.forEach(System.out::println);
37+
38+
}
39+
}

src/com/winterbe/java8/Streams9.java

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
package com.winterbe.java8;
2+
3+
import java.util.Arrays;
4+
5+
/**
6+
* @author Benjamin Winterberg
7+
*/
8+
public class Streams9 {
9+
10+
public static void main(String[] args) {
11+
Arrays.asList("a1", "a2", "b1", "c2", "c1")
12+
.stream()
13+
.filter(s -> s.startsWith("c"))
14+
.map(String::toUpperCase)
15+
.sorted()
16+
.forEach(System.out::println);
17+
18+
// C1
19+
// C2
20+
}
21+
}

0 commit comments

Comments
 (0)