Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion .idea/misc.xml

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

52 changes: 34 additions & 18 deletions .idea/workspace.xml

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

29 changes: 20 additions & 9 deletions src/main/java/io/javabrains/reactiveworkshop/Exercise1.java
Original file line number Diff line number Diff line change
Expand Up @@ -7,24 +7,35 @@ public static void main(String[] args) {
// Use StreamSources.intNumbersStream() and StreamSources.userStream()

// Print all numbers in the intNumbersStream stream
// TODO: Write code here
StreamSources.intNumbersStream()
.forEach(number -> System.out.print(number + " "));
System.out.println();

// Print numbers from intNumbersStream that are less than 5
// TODO: Write code here
StreamSources.intNumbersStream().filter(number -> number > 5)
.forEach(number -> System.out.print(number + " "));
System.out.println();

// Print the second and third numbers in intNumbersStream that's greater than 5
// TODO: Write code here

StreamSources.intNumbersStream().filter(number -> number > 5)
.skip(1)
.limit(2).forEach(number -> System.out.print(number + " "));
System.out.println();
// Print the first number in intNumbersStream that's greater than 5.
// If nothing is found, print -1
// TODO: Write code here
Integer firstVal = StreamSources.intNumbersStream().filter(number -> number > 5)
.findFirst()
.orElse(-1);
System.out.println(firstVal);

// Print first names of all users in userStream
// TODO: Write code here

StreamSources.userStream().forEach(firstName -> System.out.print(firstName.getFirstName() + " "));
System.out.println();
// Print first names in userStream for users that have IDs from number stream
// TODO: Write code here

StreamSources.intNumbersStream()
.flatMap((id -> StreamSources.userStream().filter(user -> user.getId() == id)))
.map(user -> user.getFirstName())
.forEach(userName -> System.out.print(userName + " "));
}

}