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

fixed typo (#30218)

Browse source
This commit is contained in:
Seeta Ramayya 2021-05-05 13:20:10 +02:00 • committed by GitHub
parent 1a36631dbb
commit 174c725ef8
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-docs/src/test/java/jdocs/stream/operators/flow/StatefulMapConcat.java
View file

@ -57,7 +57,7 @@ public class StatefulMapConcat {
return (element) -> {
if (element.startsWith("deny:")) {
denyList.add(element.substring(10));
denyList.add(element.substring("deny:".length()));
return Collections
.emptyList(); // no element downstream when adding a deny listed keyword
} else if (denyList.contains(element)) {

2
akka-docs/src/test/scala/docs/stream/operators/flow/StatefulMapConcat.scala
View file

@ -44,7 +44,7 @@ class StatefulMapConcat {
{ element =>
if (element.startsWith("deny:")) {
denyList += element.drop(10)
denyList += element.drop("deny:".size)
Nil // no element downstream when adding a deny listed keyword
} else if (denyList(element)) {
Nil // no element downstream if element is deny listed