raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Add optionalVia and unsafeOptionalDataVia

Browse source
This commit is contained in:
Matthew de Detrich 2024-08-01 23:00:48 +02:00
parent 0fa708382c
commit 60c480aecd
17 changed files with 502 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

17
docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java
View file

@ -532,6 +532,23 @@ class SourceOrFlow {
// #foldAsync
}
void optionalViaExample() {
// #optionalVia
Flow<String, Integer, NotUsed> flow = Flow.fromFunction(Integer::parseInt);
Source<Optional<String>, NotUsed> source =
Source.from(
Arrays.asList(Optional.of("1"), Optional.empty(), Optional.empty(), Optional.of("4")));
Source.optionalVia(source, flow, Keep.none()).runForeach(System.out::println, system);
// Optional[1]
// Optional.empty
// Optional.empty
// Optional[4]
// #optionalVia
}
void takeExample() {
// #take
Source.from(Arrays.asList(1, 2, 3, 4, 5)).take(3).runForeach(System.out::println, system);