From 411a11dd9d1d739673cd38ec9238f31a3a084062 Mon Sep 17 00:00:00 2001 From: Ignasi Marimon-Clos Date: Tue, 9 Jun 2020 15:55:43 +0200 Subject: [PATCH] No commit without a formatting follwup --- .../java/jdocs/stream/operators/sourceorflow/Throttle.java | 3 +-- .../scala/docs/stream/operators/sourceorflow/Throttle.scala | 4 +--- 2 files changed, 2 insertions(+), 5 deletions(-) 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