Fix doc typo (#29326)
This commit is contained in:
parent
e8e43be3fe
commit
6130b33e08
1 changed files with 1 additions and 1 deletions
|
|
@ -36,7 +36,7 @@ public class PartitionDocExample {
|
||||||
.to(Sink.ignore());
|
.to(Sink.ignore());
|
||||||
Sink<Integer, NotUsed> odd =
|
Sink<Integer, NotUsed> odd =
|
||||||
Flow.of(Integer.class)
|
Flow.of(Integer.class)
|
||||||
.log("even")
|
.log("odd")
|
||||||
.withAttributes(Attributes.createLogLevels(Attributes.logLevelInfo()))
|
.withAttributes(Attributes.createLogLevels(Attributes.logLevelInfo()))
|
||||||
.to(Sink.ignore());
|
.to(Sink.ignore());
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue