This is an automated email from the ASF dual-hosted git repository. hepin pushed a commit to branch follow in repository https://gitbox.apache.org/repos/asf/pekko.git
commit 1f40d35d461eb67852d5f9122604352751fccbf1 Author: He-Pin <[email protected]> AuthorDate: Sat Aug 30 11:59:18 2025 +0800 chore: Remove left org.apache.pekko.japi.Function in doc --- actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala | 2 +- actor/src/main/scala/org/apache/pekko/pattern/extended/package.scala | 2 +- docs/src/main/paradox/persistence.md | 4 ++-- docs/src/main/paradox/typed/interaction-patterns.md | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) 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 0e87f91332..2465aeccd8 100644 --- a/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala +++ b/actor/src/main/scala/org/apache/pekko/pattern/Patterns.scala @@ -348,7 +348,7 @@ object Patterns { * {{{ * final Future<Object> f = Patterns.ask(worker, request, timeout); * // apply some transformation (i.e. enrich with request info) - * final Future<Object> transformed = f.map(new org.apache.pekko.japi.Function<Object, Object>() { ... }); + * final Future<Object> transformed = f.map(new org.apache.pekko.japi.function.Function<Object, Object>() { ... }); * // send it on to the next operator * Patterns.pipe(transformed, context).to(nextActor); * }}} diff --git a/actor/src/main/scala/org/apache/pekko/pattern/extended/package.scala b/actor/src/main/scala/org/apache/pekko/pattern/extended/package.scala index 339c155105..971364093f 100644 --- a/actor/src/main/scala/org/apache/pekko/pattern/extended/package.scala +++ b/actor/src/main/scala/org/apache/pekko/pattern/extended/package.scala @@ -42,7 +42,7 @@ package pattern * {{{ * import static org.apache.pekko.pattern.Patterns.ask; * - * ask(actor, new org.apache.pekko.japi.Function<ActorRef, Object> { + * ask(actor, new org.apache.pekko.japi.function.Function<ActorRef, Object> { * Object apply(ActorRef askSender) { * return new Request(askSender); * } diff --git a/docs/src/main/paradox/persistence.md b/docs/src/main/paradox/persistence.md index 21147b0dc0..7bc29a81a4 100644 --- a/docs/src/main/paradox/persistence.md +++ b/docs/src/main/paradox/persistence.md @@ -688,7 +688,7 @@ an actor selection. @@@ -Use the @scala[@scaladoc[deliver](org.apache.pekko.persistence.AtLeastOnceDelivery#deliver(destination:org.apache.pekko.actor.ActorPath)(deliveryIdToMessage:Long=%3EAny):Unit)]@java[@javadoc[deliver](pekko.persistence.AbstractPersistentActorWithAtLeastOnceDelivery#deliver(org.apache.pekko.actor.ActorPath,org.apache.pekko.japi.Function))] method to send a message to a destination. Call the @scala[@scaladoc[confirmDelivery](org.apache.pekko.persistence.AtLeastOnceDelivery#confirmDelivery(d [...] +Use the @scala[@scaladoc[deliver](org.apache.pekko.persistence.AtLeastOnceDelivery#deliver(destination:org.apache.pekko.actor.ActorPath)(deliveryIdToMessage:Long=%3EAny):Unit)]@java[@javadoc[deliver](pekko.persistence.AbstractPersistentActorWithAtLeastOnceDelivery#deliver(org.apache.pekko.actor.ActorPath,org.apache.pekko.japi.function.Function))] method to send a message to a destination. Call the @scala[@scaladoc[confirmDelivery](org.apache.pekko.persistence.AtLeastOnceDelivery#confirmD [...] when the destination has replied with a confirmation message. ### Relationship between deliver and confirmDelivery @@ -727,7 +727,7 @@ of your message has replied with your custom correlation id. The @scala[@scaladoc[AtLeastOnceDelivery](pekko.persistence.AtLeastOnceDelivery) trait]@java[@javadoc[AbstractPersistentActorWithAtLeastOnceDelivery](pekko.persistence.AbstractPersistentActorWithAtLeastOnceDelivery) class] has a state consisting of unconfirmed messages and a sequence number. It does not store this state itself. You must persist events corresponding to the -@scala[@scaladoc[deliver](pekko.persistence.AtLeastOnceDelivery#deliver(destination:org.apache.pekko.actor.ActorPath)(deliveryIdToMessage:Long=%3EAny):Unit)]@java[@javadoc[deliver](pekko.persistence.AbstractPersistentActorWithAtLeastOnceDelivery#deliver(org.apache.pekko.actor.ActorPath,org.apache.pekko.japi.Function))] and @scala[@scaladoc[confirmDelivery](pekko.persistence.AtLeastOnceDelivery#confirmDelivery(deliveryId:Long):Boolean)]@java[@javadoc[confirmDelivery](pekko.persistence.AtL [...] +@scala[@scaladoc[deliver](pekko.persistence.AtLeastOnceDelivery#deliver(destination:org.apache.pekko.actor.ActorPath)(deliveryIdToMessage:Long=%3EAny):Unit)]@java[@javadoc[deliver](pekko.persistence.AbstractPersistentActorWithAtLeastOnceDelivery#deliver(org.apache.pekko.actor.ActorPath,org.apache.pekko.japi.function.Function))] and @scala[@scaladoc[confirmDelivery](pekko.persistence.AtLeastOnceDelivery#confirmDelivery(deliveryId:Long):Boolean)]@java[@javadoc[confirmDelivery](pekko.persis [...] be restored by calling the same methods during the recovery phase of the `PersistentActor`. Sometimes these events can be derived from other business level events, and sometimes you must create separate events. During recovery, calls to `deliver` will not send out messages, those will be sent later diff --git a/docs/src/main/paradox/typed/interaction-patterns.md b/docs/src/main/paradox/typed/interaction-patterns.md index fac3197166..a0ded8413a 100644 --- a/docs/src/main/paradox/typed/interaction-patterns.md +++ b/docs/src/main/paradox/typed/interaction-patterns.md @@ -482,7 +482,7 @@ Java There are a few things worth noting here: * To get access to the timers you start with @apidoc[Behaviors.withTimers](typed.*.Behaviors$) {scala="#withTimers[T](factory:org.apache.pekko.actor.typed.scaladsl.TimerScheduler[T]=%3eorg.apache.pekko.actor.typed.Behavior[T]):org.apache.pekko.actor.typed.Behavior[T]" java="#withTimers(org.apache.pekko.japi.function.Function)"} that will pass a @apidoc[actor.typed.*.TimerScheduler] instance to the function. -This can be used with any type of @apidoc[actor.typed.Behavior], including @apidoc[receive](typed.*.Behaviors$) {scala="#receive[T](onMessage:(org.apache.pekko.actor.typed.scaladsl.ActorContext[T],T)=%3Eorg.apache.pekko.actor.typed.Behavior[T]):org.apache.pekko.actor.typed.scaladsl.Behaviors.Receive[T]" java="#receive(org.apache.pekko.japi.function.Function2,org.apache.pekko.japi.function.Function2)"}, @apidoc[receiveMessage](typed.*.Behaviors$) {scala="#receiveMessage[T](onMessage:T=%3E [...] +This can be used with any type of @apidoc[actor.typed.Behavior], including @apidoc[receive](typed.*.Behaviors$) {scala="#receive[T](onMessage:(org.apache.pekko.actor.typed.scaladsl.ActorContext[T],T)=%3Eorg.apache.pekko.actor.typed.Behavior[T]):org.apache.pekko.actor.typed.scaladsl.Behaviors.Receive[T]" java="#receive(org.apache.pekko.japi.function.Function2,org.apache.pekko.japi.function.Function2)"}, @apidoc[receiveMessage](typed.*.Behaviors$) {scala="#receiveMessage[T](onMessage:T=%3E [...] * Each timer has a key and if a new timer with the same key is started, the previous is cancelled. It is guaranteed that a message from the previous timer is not received, even if it was already enqueued in the mailbox when the new timer was started. * Both periodic and single message timers are supported. * The `TimerScheduler` is mutable in itself, because it performs and manages the side effects of registering the scheduled tasks. --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
