This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new f879bbb553 chore: Remove left org.apache.pekko.japi.Function in doc
(#2105)
f879bbb553 is described below
commit f879bbb5539c497ebc9df3ab5995716253f0a73b
Author: He-Pin(kerr) <[email protected]>
AuthorDate: Sat Aug 30 16:40:46 2025 +0800
chore: Remove left org.apache.pekko.japi.Function in doc (#2105)
---
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]
