This is an automated email from the ASF dual-hosted git repository. hepin pushed a commit to branch timeoutCompletionStage in repository https://gitbox.apache.org/repos/asf/pekko.git
commit 0c6233b58b4909577532edd19fa89d654d087e12 Author: He-Pin <[email protected]> AuthorDate: Sat Aug 23 18:09:42 2025 +0800 chore: Make timeoutCompletionStage accept java Duration. --- .../src/main/scala/org/apache/pekko/pattern/FutureTimeoutSupport.scala | 2 +- actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/actor/src/main/scala/org/apache/pekko/pattern/FutureTimeoutSupport.scala b/actor/src/main/scala/org/apache/pekko/pattern/FutureTimeoutSupport.scala index f936994601..46e156e365 100644 --- a/actor/src/main/scala/org/apache/pekko/pattern/FutureTimeoutSupport.scala +++ b/actor/src/main/scala/org/apache/pekko/pattern/FutureTimeoutSupport.scala @@ -123,7 +123,7 @@ trait FutureTimeoutSupport { * if the provided value is not completed within the specified duration. * @since 1.2.0 */ - def timeoutCompletionStage[T](duration: FiniteDuration, using: Scheduler)(value: => CompletionStage[T])( + def timeoutCompletionStage[T](duration: java.time.Duration, using: Scheduler)(value: => CompletionStage[T])( implicit ec: ExecutionContext): CompletionStage[T] = { val stage: CompletionStage[T] = try value diff --git a/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala b/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala index b776be1f08..71dc12e1d9 100644 --- a/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala +++ b/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala @@ -476,7 +476,7 @@ object Patterns { scheduler: Scheduler, context: ExecutionContext, value: Callable[CompletionStage[T]]): CompletionStage[T] = - timeoutCompletionStage(duration.asScala, scheduler)(value.call())(context) + timeoutCompletionStage(duration, scheduler)(value.call())(context) /** * Returns an internally retrying [[java.util.concurrent.CompletionStage]] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
