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

=doc Update java code sample of StatefulMap. (#26)

Browse source
This commit is contained in:
kerr 2022-11-08 19:31:28 +08:00 • committed by GitHub
parent a402730fd3
commit 0c4c9e6a6d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

14
akka-docs/src/test/java/jdocs/stream/operators/flow/StatefulMap.java
View file

@ -4,7 +4,7 @@
package jdocs.stream.operators.flow;
import akka.actor.typed.ActorSystem;
import akka.actor.ActorSystem;
import akka.japi.Pair;
import akka.stream.javadsl.Flow;
import akka.stream.javadsl.Source;
@ -13,7 +13,7 @@ import java.util.*;
import java.util.stream.IntStream;
public class StatefulMap {
static final ActorSystem<?> system = null;
static final ActorSystem system = null;
public void indexed() {
// #zipWithIndex
@ -35,10 +35,7 @@ public class StatefulMap {
// #bufferUntilChanged
Source.from(Arrays.asList("A", "B", "B", "C", "C", "C", "D"))
.statefulMap(
() -> {
final List<String> buffer = new LinkedList<>();
return buffer;
},
() -> (List<String>) new LinkedList<String>(),
(buffer, element) -> {
if (buffer.size() > 0 && (!buffer.get(0).equals(element))) {
return Pair.create(
@ -49,7 +46,8 @@ public class StatefulMap {
return Pair.create(buffer, Collections.<String>emptyList());
}
},
listOnComplete -> Optional.ofNullable(listOnComplete))
Optional::ofNullable)
.filterNot(List::isEmpty)
.runForeach(System.out::println, system);
// prints
// [A]
@ -95,7 +93,7 @@ public class StatefulMap {
return Pair.create(list, Collections.<Integer>emptyList());
}
},
listOnComplete -> Optional.ofNullable(listOnComplete))
Optional::ofNullable)
.mapConcat(list -> list)
.runForeach(System.out::println, system);
// prints