diff --git a/.github/workflows/scala3-build.yml b/.github/workflows/scala3-build.yml index 059c5ba40d..0dd2905b3e 100644 --- a/.github/workflows/scala3-build.yml +++ b/.github/workflows/scala3-build.yml @@ -26,7 +26,7 @@ jobs: - akka-persistence/test akka-persistence-shared/test akka-persistence-query/test akka-persistence-typed/test akka-persistence-testkit/test - akka-pki/test akka-slf4j/test - akka-serialization-jackson/test - - akka-stream/test akka-stream-testkit/test akka-stream-tests/test + - akka-stream/test akka-stream-testkit/test akka-stream-tests/test akka-stream-typed/test - akka-stream-tests-tck/test - akka-remote/test akka-remote-tests/test akka-protobuf/test akka-protobuf-v3/test fail-fast: true diff --git a/.github/workflows/scala3-compile.yml b/.github/workflows/scala3-compile.yml index 9cf6013c6b..412e037192 100644 --- a/.github/workflows/scala3-compile.yml +++ b/.github/workflows/scala3-compile.yml @@ -24,7 +24,7 @@ jobs: - akka-persistence/Test/compile akka-persistence-shared/Test/compile akka-persistence-query/Test/compile akka-persistence-typed/Test/compile akka-persistence-testkit/Test/compile - akka-pki/Test/compile akka-slf4j/Test/compile - akka-serialization-jackson/Test/compile - - akka-stream/Test/compile akka-stream-testkit/Test/compile akka-stream-tests/Test/compile + - akka-stream/Test/compile akka-stream-testkit/Test/compile akka-stream-tests/Test/compile akka-stream-typed/Test/compile - akka-stream-tests-tck/Test/compile - akka-remote/Test/compile akka-remote-tests/Test/compile akka-protobuf/Test/compile akka-protobuf-v3/Test/compile fail-fast: true diff --git a/akka-stream-typed/src/test/scala/docs/scaladsl/ActorFlowSpec.scala b/akka-stream-typed/src/test/scala/docs/scaladsl/ActorFlowSpec.scala index 1b257c5229..04cec8223b 100644 --- a/akka-stream-typed/src/test/scala/docs/scaladsl/ActorFlowSpec.scala +++ b/akka-stream-typed/src/test/scala/docs/scaladsl/ActorFlowSpec.scala @@ -11,6 +11,7 @@ import akka.stream.scaladsl.{ Flow, Sink, Source } import akka.stream.typed.scaladsl.ActorFlow import akka.actor.typed.ActorRef import akka.actor.typed.scaladsl.Behaviors +import akka.util.Timeout //#imports import akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit @@ -110,7 +111,7 @@ class ActorFlowSpec extends ScalaTestWithActorTestKit with AnyWordSpecLike { //#ask-actor //#ask - implicit val timeout: akka.util.Timeout = 1.second + implicit val timeout: Timeout = 1.second val askFlow: Flow[String, Reply, NotUsed] = ActorFlow.ask(ref)(Asking.apply) @@ -132,7 +133,7 @@ class ActorFlowSpec extends ScalaTestWithActorTestKit with AnyWordSpecLike { val dontReply = spawn(Behaviors.ignore[Asking]) val c = TestSubscriber.manualProbe[Reply]()(system.toClassic) - implicit val timeout = akka.util.Timeout(10.millis) + implicit val timeout: Timeout = 10.millis Source(1 to 5) .map(_.toString + " nope")