This is an automated email from the ASF dual-hosted git repository.
fanningpj 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 c38ce16d36 refactor some more casts (#2090)
c38ce16d36 is described below
commit c38ce16d365654b92be1dfb907704114a3a66444
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Aug 25 15:23:29 2025 +0100
refactor some more casts (#2090)
* refactor some more casts
* Update ReplicatorDocSample.java
---
.../src/test/java/jdocs/delivery/ShardingDocExample.java | 8 +++-----
.../typed/DurableStateStoreQueryUsageCompileOnlyTest.java | 3 +--
.../pekko/cluster/ddata/typed/javadsl/ReplicatorDocSample.java | 8 ++++----
3 files changed, 8 insertions(+), 11 deletions(-)
diff --git
a/cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java
b/cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java
index 93446205e2..768a0e05e2 100644
---
a/cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java
+++
b/cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java
@@ -98,7 +98,7 @@ interface ShardingDocExample {
final Exception cause;
private DBError(Throwable cause) {
- if (cause instanceof Exception) this.cause = (Exception) cause;
+ if (cause instanceof Exception exception) this.cause = exception;
else this.cause = new RuntimeException(cause.getMessage(), cause);
}
}
@@ -221,13 +221,11 @@ interface ShardingDocExample {
}
private Behavior<Command> onDelivery(CommandDelivery delivery) {
- if (delivery.command instanceof AddTask) {
- AddTask addTask = (AddTask) delivery.command;
+ if (delivery.command instanceof AddTask addTask) {
state = state.add(addTask.item);
save(state, delivery.confirmTo);
return this;
- } else if (delivery.command instanceof CompleteTask) {
- CompleteTask completeTask = (CompleteTask) delivery.command;
+ } else if (delivery.command instanceof CompleteTask completeTask) {
state = state.remove(completeTask.item);
save(state, delivery.confirmTo);
return this;
diff --git
a/cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/DurableStateStoreQueryUsageCompileOnlyTest.java
b/cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/DurableStateStoreQueryUsageCompileOnlyTest.java
index 8ae0e843e5..9d2bfd7fa9 100644
---
a/cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/DurableStateStoreQueryUsageCompileOnlyTest.java
+++
b/cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/DurableStateStoreQueryUsageCompileOnlyTest.java
@@ -39,8 +39,7 @@ class DurableStateStoreQueryUsageCompileOnlySpec {
durableStateStoreQuery.changes("tag", offset);
source.map(
chg -> {
- if (chg instanceof UpdatedDurableState) {
- UpdatedDurableState<Record> upd = (UpdatedDurableState<Record>)
chg;
+ if (chg instanceof UpdatedDurableState upd) {
return upd.value();
} else {
throw new IllegalArgumentException("Unexpected DurableStateChange
" + chg.getClass());
diff --git
a/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorDocSample.java
b/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorDocSample.java
index fc32afa532..5878f3ac22 100644
---
a/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorDocSample.java
+++
b/cluster-typed/src/test/java/jdocs/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorDocSample.java
@@ -167,8 +167,8 @@ interface ReplicatorDocSample {
}
private Behavior<Command> onInternalGetResponse(InternalGetResponse msg) {
- if (msg.rsp instanceof Replicator.GetSuccess) {
- int value = ((Replicator.GetSuccess<?>)
msg.rsp).get(key).getValue().intValue();
+ if (msg.rsp instanceof Replicator.GetSuccess<GCounter> rsp) {
+ int value = rsp.get(key).getValue().intValue();
msg.replyTo.tell(value);
return this;
} else {
@@ -178,8 +178,8 @@ interface ReplicatorDocSample {
}
private Behavior<Command>
onInternalSubscribeResponse(InternalSubscribeResponse msg) {
- if (msg.rsp instanceof Replicator.Changed) {
- GCounter counter = ((Replicator.Changed<?>) msg.rsp).get(key);
+ if (msg.rsp instanceof Replicator.Changed<GCounter> rsp) {
+ GCounter counter = rsp.get(key);
cachedValue = counter.getValue().intValue();
return this;
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
