-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
17 changed files
with
39 additions
and
622 deletions.
There are no files selected for viewing
39 changes: 39 additions & 0 deletions
39
training/src/main/java/info/jab/fp/stream/StreamExamples.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,39 @@ | ||
package info.jab.fp.stream; | ||
|
||
import java.util.List; | ||
import java.util.stream.Collectors; | ||
import java.util.stream.Gatherers; | ||
|
||
public class StreamExamples { | ||
|
||
public void example1() { | ||
var text = """ | ||
item1 | ||
item2 | ||
-- | ||
item11 | ||
item12 | ||
"""; | ||
|
||
var result = text.lines() | ||
.gather(Gatherers.windowFixed(2)) | ||
.toList(); | ||
} | ||
|
||
public void example2() { | ||
var text = """ | ||
item1 | ||
item2 | ||
-- | ||
item11 | ||
item12 | ||
"""; | ||
|
||
var result = text.lines() | ||
.gather(Gatherers.fold(() -> 0, (value, s) -> value + 1)) | ||
.findFirst().orElseThrow(); | ||
|
||
System.out.println(result); | ||
} | ||
|
||
} |
48 changes: 0 additions & 48 deletions
48
training/src/main/java/info/jab/fp/stream/gatherers/_10_collector_as_gatherer.java
This file was deleted.
Oops, something went wrong.
24 changes: 0 additions & 24 deletions
24
training/src/main/java/info/jab/fp/stream/gatherers/_11_map.java
This file was deleted.
Oops, something went wrong.
42 changes: 0 additions & 42 deletions
42
training/src/main/java/info/jab/fp/stream/gatherers/_12_windowFixed.java
This file was deleted.
Oops, something went wrong.
31 changes: 0 additions & 31 deletions
31
training/src/main/java/info/jab/fp/stream/gatherers/_13_fold.java
This file was deleted.
Oops, something went wrong.
36 changes: 0 additions & 36 deletions
36
training/src/main/java/info/jab/fp/stream/gatherers/_14_reduce.java
This file was deleted.
Oops, something went wrong.
39 changes: 0 additions & 39 deletions
39
training/src/main/java/info/jab/fp/stream/gatherers/_15_print_characteristics.java
This file was deleted.
Oops, something went wrong.
27 changes: 0 additions & 27 deletions
27
training/src/main/java/info/jab/fp/stream/gatherers/_18_findIndex.java
This file was deleted.
Oops, something went wrong.
29 changes: 0 additions & 29 deletions
29
training/src/main/java/info/jab/fp/stream/gatherers/_1_starting_thread.java
This file was deleted.
Oops, something went wrong.
54 changes: 0 additions & 54 deletions
54
training/src/main/java/info/jab/fp/stream/gatherers/_20_gatherer_windowBy.java
This file was deleted.
Oops, something went wrong.
Oops, something went wrong.