fix: fixing eventing testkit timeout

lightbend · Nov 13, 2023 · 4c56f08 · 4c56f08
1 parent 7701f11
commit 4c56f08
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-sdk-protobuf-testkit/src/main/scala/kalix/javasdk/testkit/impl/EventingTestKitImpl.scala b/...-sdk-protobuf-testkit/src/main/scala/kalix/javasdk/testkit/impl/EventingTestKitImpl.scala
@@ -503,7 +503,7 @@ private[testkit] class TopicImpl(
     expectOneTyped(clazz, DefaultTimeout)
 
   override def expectOneTyped[T](clazz: Class[T], timeout: time.Duration): TestKitMessage[T] = {
-    val msg = destinationProbe.expectMsgType[EmitSingleCommand]
+    val msg = destinationProbe.expectMsgType[EmitSingleCommand](timeout.toScala)
     val metadata = new MetadataImpl(msg.getMessage.getMetadata.entries)
     val scalaPb = ScalaPbAny(typeUrlFor(metadata), msg.getMessage.payload)