raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

use java Predicate in Java API

Browse source
This commit is contained in:
Renato Cavalcanti 2021-01-07 21:06:31 +01:00
parent e8e62e2ca2
commit 4132507486
No known key found for this signature in database
GPG key ID: 75C015C04523E07C
2 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-actor-typed/src/main/scala/akka/actor/typed/internal/StashBufferImpl.scala
View file

@ -4,7 +4,6 @@
package akka.actor.typed.internal
import java.util.function.{ Function => JFunction }
import scala.annotation.tailrec
import scala.util.control.NonFatal
import akka.actor.DeadLetter
@ -15,10 +14,13 @@ import akka.actor.typed.javadsl
import akka.actor.typed.scaladsl
import akka.actor.typed.scaladsl.ActorContext
import akka.annotation.{ InternalApi, InternalStableApi }
import akka.japi.function.{ Predicate, Procedure }
import akka.japi.function.Procedure
import akka.util.{ unused, ConstantFun }
import akka.util.OptionVal
import java.util.function.{ Function => JFunction }
import java.util.function.Predicate
/**
* INTERNAL API
*/

4
akka-actor-typed/src/main/scala/akka/actor/typed/javadsl/StashBuffer.scala
View file

@ -6,9 +6,9 @@ package akka.actor.typed.javadsl
import akka.actor.typed.{ scaladsl, Behavior }
import akka.annotation.DoNotInherit
import akka.japi.function.{ Predicate, Procedure }
import akka.japi.function.Procedure
import java.util.function.{ Function => JFunction }
import java.util.function.{ Predicate, Function => JFunction }
/**
* A non thread safe mutable message buffer that can be used to buffer messages inside actors