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

!per #15644 Rename persist(seq) to persistAll

Browse source
This commit is contained in:
Patrik Nordwall 2015-06-16 12:10:49 +02:00
parent 314b00053c
commit 74b97b3bd4
8 changed files with 46 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

22
akka-persistence/src/main/scala/akka/persistence/PersistentActor.scala
View file

@ -167,8 +167,12 @@ abstract class UntypedPersistentActor extends UntypedActor with Eventsourced wit
* @param events events to be persisted.
* @param handler handler for each persisted `events`
*/
final def persistAll[A](events: JIterable[A], handler: Procedure[A]): Unit =
persistAll(Util.immutableSeq(events))(event ⇒ handler(event))
@deprecated("use persistAll instead", "2.4")
final def persist[A](events: JIterable[A], handler: Procedure[A]): Unit =
persist(Util.immutableSeq(events))(event ⇒ handler(event))
persistAll(events, handler)
/**
* JAVA API: asynchronously persists `event`. On successful persistence, `handler` is called with the
@ -200,8 +204,8 @@ abstract class UntypedPersistentActor extends UntypedActor with Eventsourced wit
* @param events events to be persisted
* @param handler handler for each persisted `events`
*/
final def persistAsync[A](events: JIterable[A])(handler: A ⇒ Unit): Unit =
super[Eventsourced].persistAsync(Util.immutableSeq(events))(event ⇒ handler(event))
final def persistAllAsync[A](events: JIterable[A], handler: Procedure[A]): Unit =
super[Eventsourced].persistAllAsync(Util.immutableSeq(events))(event ⇒ handler(event))
/**
* Defer the handler execution until all pending handlers have been executed.
@ -288,8 +292,12 @@ abstract class AbstractPersistentActor extends AbstractActor with PersistentActo
* @param events events to be persisted.
* @param handler handler for each persisted `events`
*/
final def persistAll[A](events: JIterable[A], handler: Procedure[A]): Unit =
persistAll(Util.immutableSeq(events))(event ⇒ handler(event))
@deprecated("use persistAll instead", "2.4")
final def persist[A](events: JIterable[A], handler: Procedure[A]): Unit =
persist(Util.immutableSeq(events))(event ⇒ handler(event))
persistAll(events, handler)
/**
* Java API: asynchronously persists `event`. On successful persistence, `handler` is called with the
@ -316,8 +324,12 @@ abstract class AbstractPersistentActor extends AbstractActor with PersistentActo
* @param events events to be persisted
* @param handler handler for each persisted `events`
*/
final def persistAllAsync[A](events: JIterable[A], handler: Procedure[A]): Unit =
persistAllAsync(Util.immutableSeq(events))(event ⇒ handler(event))
@deprecated("use persistAllAsync instead", "2.4")
final def persistAsync[A](events: JIterable[A], handler: Procedure[A]): Unit =
persistAsync(Util.immutableSeq(events))(event ⇒ handler(event))
persistAllAsync(events, handler)
/**
* Defer the handler execution until all pending handlers have been executed.