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

add async to sinks in broadcast async doc (#28589)

Browse source
This commit is contained in:
George Leung 2022-04-14 04:58:21 -04:00 • committed by GitHub
parent d9303dfdaa
commit f6d880fed9
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 16 additions and 27 deletions
Download patch file Download diff file Expand all files Collapse all files

25
akka-docs/src/test/java/jdocs/stream/operators/BroadcastDocExample.java
View file

@ -23,9 +23,9 @@ import java.util.concurrent.CompletionStage;
public class BroadcastDocExample {
private final ActorSystem system = ActorSystem.create("PartitionDocExample");
private final ActorSystem system = ActorSystem.create("BroadcastDocExample");
void partitionExample() {
void broadcastExample() {
// #broadcast
@ -62,27 +62,18 @@ public class BroadcastDocExample {
// #broadcast-async
RunnableGraph.fromGraph(
GraphDSL.create3(
countSink,
minSink,
maxSink,
countSink.async(),
minSink.async(),
maxSink.async(),
Tuple3::create,
(builder, countS, minS, maxS) -> {
final UniformFanOutShape<Integer, Integer> broadcast =
builder.add(Broadcast.create(3));
builder.from(builder.add(source)).viaFanOut(broadcast);
builder
.from(broadcast.out(0))
.via(builder.add(Flow.of(Integer.class).async()))
.to(countS);
builder
.from(broadcast.out(1))
.via(builder.add(Flow.of(Integer.class).async()))
.to(minS);
builder
.from(broadcast.out(2))
.via(builder.add(Flow.of(Integer.class).async()))
.to(maxS);
builder.from(broadcast.out(0)).to(countS);
builder.from(broadcast.out(1)).to(minS);
builder.from(broadcast.out(2)).to(maxS);
return ClosedShape.getInstance();
}));
// #broadcast-async