Skip to content

Commit f9a8c96

Browse files
committed
Use stdlib IntFunction to not allow throwing
1 parent 0f6def6 commit f9a8c96

File tree

3 files changed

+3
-58
lines changed

3 files changed

+3
-58
lines changed

actor/src/main/java/org/apache/pekko/japi/function/IntFunction.java

Lines changed: 0 additions & 37 deletions
This file was deleted.

actor/src/main/java/org/apache/pekko/japi/function/package-info.java

Lines changed: 0 additions & 19 deletions
This file was deleted.

actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@ package org.apache.pekko.pattern
1515

1616
import java.util.Optional
1717
import java.util.concurrent.{ Callable, CompletionStage, TimeUnit }
18+
import java.util.function.IntFunction
1819

1920
import scala.concurrent.ExecutionContext
2021

@@ -812,7 +813,7 @@ object Patterns {
812813
def retry[T](
813814
attempt: Callable[CompletionStage[T]],
814815
attempts: Int,
815-
delayFunction: japi.function.IntFunction[Optional[java.time.Duration]],
816+
delayFunction: IntFunction[Optional[java.time.Duration]],
816817
scheduler: Scheduler,
817818
context: ExecutionContext): CompletionStage[T] = {
818819
import pekko.util.OptionConverters._
@@ -853,7 +854,7 @@ object Patterns {
853854
attempt: Callable[CompletionStage[T]],
854855
shouldRetry: japi.function.Predicate2[T, Throwable],
855856
attempts: Int,
856-
delayFunction: japi.function.IntFunction[Optional[java.time.Duration]],
857+
delayFunction: IntFunction[Optional[java.time.Duration]],
857858
scheduler: Scheduler,
858859
context: ExecutionContext): CompletionStage[T] = {
859860
import pekko.util.OptionConverters._

0 commit comments

Comments
 (0)