diff --git a/akka-docs/rst/scala/code/docs/http/scaladsl/server/directives/DebuggingDirectivesExamplesSpec.scala b/akka-docs/rst/scala/code/docs/http/scaladsl/server/directives/DebuggingDirectivesExamplesSpec.scala index 18ff2eae4b..6c32784c76 100644 --- a/akka-docs/rst/scala/code/docs/http/scaladsl/server/directives/DebuggingDirectivesExamplesSpec.scala +++ b/akka-docs/rst/scala/code/docs/http/scaladsl/server/directives/DebuggingDirectivesExamplesSpec.scala @@ -4,11 +4,11 @@ package docs.http.scaladsl.server.directives -import akka.event.{LoggingAdapter, Logging} +import akka.event.{ LoggingAdapter, Logging } import akka.event.Logging.LogLevel import akka.http.scaladsl.model.{ HttpRequest, HttpResponse } import akka.http.scaladsl.server.RouteResult -import akka.http.scaladsl.server.RouteResult.{Rejected, Complete} +import akka.http.scaladsl.server.RouteResult.{ Rejected, Complete } import akka.http.scaladsl.server.directives.{ DebuggingDirectives, LogEntry, LoggingMagnet } import docs.http.scaladsl.server.RoutingSpec @@ -99,9 +99,10 @@ class DebuggingDirectivesExamplesSpec extends RoutingSpec { } "logRequestResultWithResponseTime" in { - def akkaResponseTimeLoggingFunction(loggingAdapter: LoggingAdapter, - requestTimestamp: Long, - level: LogLevel = Logging.InfoLevel)(req: HttpRequest)(res: Any): Unit = { + def akkaResponseTimeLoggingFunction( + loggingAdapter: LoggingAdapter, + requestTimestamp: Long, + level: LogLevel = Logging.InfoLevel)(req: HttpRequest)(res: Any): Unit = { val entry = res match { case Complete(resp) => val responseTimestamp: Long = System.nanoTime diff --git a/akka-docs/rst/scala/code/docs/http/scaladsl/server/directives/FileUploadDirectivesExamplesSpec.scala b/akka-docs/rst/scala/code/docs/http/scaladsl/server/directives/FileUploadDirectivesExamplesSpec.scala index 694581f5ab..1bad238591 100644 --- a/akka-docs/rst/scala/code/docs/http/scaladsl/server/directives/FileUploadDirectivesExamplesSpec.scala +++ b/akka-docs/rst/scala/code/docs/http/scaladsl/server/directives/FileUploadDirectivesExamplesSpec.scala @@ -4,15 +4,21 @@ package docs.http.scaladsl.server.directives import akka.http.scaladsl.model._ +import akka.http.scaladsl.testkit.RouteTestTimeout import akka.stream.scaladsl.Framing import akka.util.ByteString import docs.http.scaladsl.server.RoutingSpec +import akka.testkit.TestDuration import scala.concurrent.Future +import scala.concurrent.duration._ class FileUploadDirectivesExamplesSpec extends RoutingSpec { override def testConfigSource = "akka.actor.default-mailbox.mailbox-type = \"akka.dispatch.UnboundedMailbox\"" + // test touches disk, so give it some time + implicit val routeTimeout = RouteTestTimeout(3.seconds.dilated) + "uploadedFile" in { val route =