Skip to content

Commit 62089a7

Browse files
Split or move java-streams module
1 parent 699cc10 commit 62089a7

67 files changed

Lines changed: 880 additions & 1045 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
## Core Java 9 streams
2+
3+
This module contains articles about Java 9 streams
4+
5+
### Relevant Articles:
6+
- [How to Break from Java Stream forEach](https://www.baeldung.com/java-break-stream-foreach)
Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
2+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
3+
<modelVersion>4.0.0</modelVersion>
4+
<artifactId>core-java-9-streams</artifactId>
5+
<version>0.1.0-SNAPSHOT</version>
6+
<name>core-java-9-streams</name>
7+
<packaging>jar</packaging>
8+
9+
<parent>
10+
<groupId>com.baeldung</groupId>
11+
<artifactId>parent-java</artifactId>
12+
<version>0.0.1-SNAPSHOT</version>
13+
<relativePath>../../parent-java</relativePath>
14+
</parent>
15+
16+
<dependencies>
17+
</dependencies>
18+
19+
<build>
20+
<finalName>core-java-9-streams</finalName>
21+
<resources>
22+
<resource>
23+
<directory>src/main/resources</directory>
24+
<filtering>true</filtering>
25+
</resource>
26+
</resources>
27+
</build>
28+
29+
<properties>
30+
</properties>
31+
</project>

java-streams-2/src/main/java/com/baeldung/breakforeach/CustomForEach.java renamed to core-java-modules/core-java-9-streams/src/main/java/com/baeldung/streams/breakforeach/CustomForEach.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.baeldung.breakforeach;
1+
package com.baeldung.streams.breakforeach;
22

33
import java.util.Spliterator;
44
import java.util.function.BiConsumer;

java-streams-2/src/main/java/com/baeldung/breakforeach/CustomSpliterator.java renamed to core-java-modules/core-java-9-streams/src/main/java/com/baeldung/streams/breakforeach/CustomSpliterator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.baeldung.breakforeach;
1+
package com.baeldung.streams.breakforeach;
22

33
import java.util.Spliterator;
44
import java.util.Spliterators;

java-streams-2/src/main/java/com/baeldung/breakforeach/CustomTakeWhile.java renamed to core-java-modules/core-java-9-streams/src/main/java/com/baeldung/streams/breakforeach/CustomTakeWhile.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.baeldung.breakforeach;
1+
package com.baeldung.streams.breakforeach;
22

33
import java.util.function.Predicate;
44
import java.util.stream.Stream;

java-streams-2/src/main/java/com/baeldung/breakforeach/TakeWhileExample.java renamed to core-java-modules/core-java-9-streams/src/main/java/com/baeldung/streams/breakforeach/TakeWhileExample.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.baeldung.breakforeach;
1+
package com.baeldung.streams.breakforeach;
22

33
import java.util.List;
44
import java.util.stream.Stream;

java-streams-2/src/test/java/com/baeldung/breakforeach/BreakFromStreamForEachUnitTest.java renamed to core-java-modules/core-java-9-streams/src/test/java/com/baeldung/streams/breakforeach/BreakFromStreamForEachUnitTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.baeldung.breakforeach;
1+
package com.baeldung.streams.breakforeach;
22

33
import org.junit.Test;
44

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
## Core Java streams
2+
3+
This module contains articles about the Stream API in Java.
4+
5+
### Relevant Articles:
6+
- [The Java 8 Stream API Tutorial](https://www.baeldung.com/java-8-streams)
7+
- [Introduction to Java 8 Streams](https://www.baeldung.com/java-8-streams-introduction)
8+
- [Java 8 Stream findFirst() vs. findAny()](https://www.baeldung.com/java-stream-findfirst-vs-findany)
9+
- [Guide to Stream.reduce()](https://www.baeldung.com/java-stream-reduce)
10+
- [Java IntStream Conversions](https://www.baeldung.com/java-intstream-convert)
11+
- [Java 8 Streams peek() API](https://www.baeldung.com/java-streams-peek-api)
12+
- [Working With Maps Using Streams](https://www.baeldung.com/java-maps-streams)
13+
- [Collect a Java Stream to an Immutable Collection](https://www.baeldung.com/java-stream-immutable-collection)
14+
- [How to Add a Single Element to a Stream](https://www.baeldung.com/java-stream-append-prepend)
15+
- [Operating on and Removing an Item from Stream](https://www.baeldung.com/java-use-remove-item-stream)
16+
- More articles: [[<-- prev>]](/../core-java-streams) [[next -->]](/../core-java-streams-3)

java-streams-2/pom.xml renamed to core-java-modules/core-java-streams-2/pom.xml

Lines changed: 52 additions & 48 deletions
Original file line numberDiff line numberDiff line change
@@ -1,49 +1,53 @@
1-
<?xml version="1.0" encoding="UTF-8"?>
2-
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
3-
<modelVersion>4.0.0</modelVersion>
4-
<groupId>com.baeldung.javastreams2</groupId>
5-
<artifactId>java-streams-2</artifactId>
6-
<version>1.0</version>
7-
<name>java-streams-2</name>
8-
<packaging>jar</packaging>
9-
10-
<parent>
11-
<groupId>com.baeldung</groupId>
12-
<artifactId>parent-java</artifactId>
13-
<version>0.0.1-SNAPSHOT</version>
14-
<relativePath>../parent-java</relativePath>
15-
</parent>
16-
17-
<dependencies>
18-
<dependency>
19-
<groupId>org.openjdk.jmh</groupId>
20-
<artifactId>jmh-core</artifactId>
21-
<version>${jmh-core.version}</version>
22-
</dependency>
23-
<dependency>
24-
<groupId>org.openjdk.jmh</groupId>
25-
<artifactId>jmh-generator-annprocess</artifactId>
26-
<version>${jmh-generator.version}</version>
27-
</dependency>
28-
<dependency>
29-
<groupId>junit</groupId>
30-
<artifactId>junit</artifactId>
31-
<version>${junit.version}</version>
32-
<scope>test</scope>
33-
<type>jar</type>
34-
</dependency>
35-
<dependency>
36-
<groupId>org.assertj</groupId>
37-
<artifactId>assertj-core</artifactId>
38-
<version>${assertj.version}</version>
39-
<scope>test</scope>
40-
</dependency>
41-
</dependencies>
42-
43-
<properties>
44-
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
45-
<maven.compiler.source>1.9</maven.compiler.source>
46-
<maven.compiler.target>1.9</maven.compiler.target>
47-
<assertj.version>3.11.1</assertj.version>
48-
</properties>
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
3+
<modelVersion>4.0.0</modelVersion>
4+
<artifactId>core-java-streams-2</artifactId>
5+
<version>1.0</version>
6+
<name>core-java-streams-2</name>
7+
<packaging>jar</packaging>
8+
9+
<parent>
10+
<groupId>com.baeldung</groupId>
11+
<artifactId>parent-java</artifactId>
12+
<version>0.0.1-SNAPSHOT</version>
13+
<relativePath>../../parent-java</relativePath>
14+
</parent>
15+
16+
<dependencies>
17+
<dependency>
18+
<groupId>org.openjdk.jmh</groupId>
19+
<artifactId>jmh-core</artifactId>
20+
<version>${jmh-core.version}</version>
21+
</dependency>
22+
<dependency>
23+
<groupId>org.openjdk.jmh</groupId>
24+
<artifactId>jmh-generator-annprocess</artifactId>
25+
<version>${jmh-generator.version}</version>
26+
</dependency>
27+
<dependency>
28+
<groupId>log4j</groupId>
29+
<artifactId>log4j</artifactId>
30+
<version>${log4j.version}</version>
31+
</dependency>
32+
<dependency>
33+
<groupId>junit</groupId>
34+
<artifactId>junit</artifactId>
35+
<version>${junit.version}</version>
36+
<scope>test</scope>
37+
<type>jar</type>
38+
</dependency>
39+
<dependency>
40+
<groupId>org.assertj</groupId>
41+
<artifactId>assertj-core</artifactId>
42+
<version>${assertj.version}</version>
43+
<scope>test</scope>
44+
</dependency>
45+
</dependencies>
46+
47+
<properties>
48+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
49+
<maven.compiler.source>1.9</maven.compiler.source>
50+
<maven.compiler.target>1.9</maven.compiler.target>
51+
<assertj.version>3.11.1</assertj.version>
52+
</properties>
4953
</project>

java-streams-2/src/main/java/com/baeldung/reduce/application/Application.java renamed to core-java-modules/core-java-streams-2/src/main/java/com/baeldung/reduce/application/Application.java

Lines changed: 39 additions & 39 deletions
Original file line numberDiff line numberDiff line change
@@ -1,39 +1,39 @@
1-
package com.baeldung.reduce.application;
2-
3-
import com.baeldung.reduce.entities.User;
4-
import com.baeldung.reduce.utilities.NumberUtils;
5-
import java.util.ArrayList;
6-
import java.util.Arrays;
7-
import java.util.List;
8-
9-
public class Application {
10-
11-
public static void main(String[] args) {
12-
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6);
13-
int result1 = numbers.stream().reduce(0, (subtotal, element) -> subtotal + element);
14-
System.out.println(result1);
15-
16-
int result2 = numbers.stream().reduce(0, Integer::sum);
17-
System.out.println(result2);
18-
19-
List<String> letters = Arrays.asList("a", "b", "c", "d", "e");
20-
String result3 = letters.stream().reduce("", (partialString, element) -> partialString + element);
21-
System.out.println(result3);
22-
23-
String result4 = letters.stream().reduce("", String::concat);
24-
System.out.println(result4);
25-
26-
String result5 = letters.stream().reduce("", (partialString, element) -> partialString.toUpperCase() + element.toUpperCase());
27-
System.out.println(result5);
28-
29-
List<User> users = Arrays.asList(new User("John", 30), new User("Julie", 35));
30-
int result6 = users.stream().reduce(0, (partialAgeResult, user) -> partialAgeResult + user.getAge(), Integer::sum);
31-
System.out.println(result6);
32-
33-
String result7 = letters.parallelStream().reduce("", String::concat);
34-
System.out.println(result7);
35-
36-
int result8 = users.parallelStream().reduce(0, (partialAgeResult, user) -> partialAgeResult + user.getAge(), Integer::sum);
37-
System.out.println(result8);
38-
}
39-
}
1+
package com.baeldung.reduce.application;
2+
3+
import com.baeldung.reduce.entities.User;
4+
import com.baeldung.reduce.utilities.NumberUtils;
5+
import java.util.ArrayList;
6+
import java.util.Arrays;
7+
import java.util.List;
8+
9+
public class Application {
10+
11+
public static void main(String[] args) {
12+
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6);
13+
int result1 = numbers.stream().reduce(0, (subtotal, element) -> subtotal + element);
14+
System.out.println(result1);
15+
16+
int result2 = numbers.stream().reduce(0, Integer::sum);
17+
System.out.println(result2);
18+
19+
List<String> letters = Arrays.asList("a", "b", "c", "d", "e");
20+
String result3 = letters.stream().reduce("", (partialString, element) -> partialString + element);
21+
System.out.println(result3);
22+
23+
String result4 = letters.stream().reduce("", String::concat);
24+
System.out.println(result4);
25+
26+
String result5 = letters.stream().reduce("", (partialString, element) -> partialString.toUpperCase() + element.toUpperCase());
27+
System.out.println(result5);
28+
29+
List<User> users = Arrays.asList(new User("John", 30), new User("Julie", 35));
30+
int result6 = users.stream().reduce(0, (partialAgeResult, user) -> partialAgeResult + user.getAge(), Integer::sum);
31+
System.out.println(result6);
32+
33+
String result7 = letters.parallelStream().reduce("", String::concat);
34+
System.out.println(result7);
35+
36+
int result8 = users.parallelStream().reduce(0, (partialAgeResult, user) -> partialAgeResult + user.getAge(), Integer::sum);
37+
System.out.println(result8);
38+
}
39+
}

0 commit comments

Comments
 (0)