scala3: test akka-stream-typed (#30910)

Refs #30243
This commit is contained in:
Arnout Engelen 2021-11-19 11:39:53 +01:00 committed by GitHub
parent 9b174a31a6
commit 65df618bd2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 4 deletions

View file

@ -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

View file

@ -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

View file

@ -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")