diff --git a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Throttle.java b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Throttle.java index d80f337491..184d256eca 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Throttle.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Throttle.java @@ -30,8 +30,7 @@ public class Throttle { int framesPerSecond = 24; Source videoThrottling = - frameSource.throttle( - framesPerSecond, Duration.ofSeconds(1)); + frameSource.throttle(framesPerSecond, Duration.ofSeconds(1)); // serialize `Frame` and send over the network. // #throttle diff --git a/akka-docs/src/test/scala/docs/stream/operators/sourceorflow/Throttle.scala b/akka-docs/src/test/scala/docs/stream/operators/sourceorflow/Throttle.scala index d07d9d992a..b4d7bf201a 100644 --- a/akka-docs/src/test/scala/docs/stream/operators/sourceorflow/Throttle.scala +++ b/akka-docs/src/test/scala/docs/stream/operators/sourceorflow/Throttle.scala @@ -26,9 +26,7 @@ object Throttle extends App { val framesPerSecond = 24 // val frameSource: Source[Frame,_] - val videoThrottling = frameSource.throttle( - framesPerSecond, - 1.second) + val videoThrottling = frameSource.throttle(framesPerSecond, 1.second) // serialize `Frame` and send over the network. // #throttle