fix typo

streamnative · Jan 26, 2025 · 49707d3 · 49707d3
1 parent 340cc97
commit 49707d3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/client/src/main/java/io/streamnative/oxia/client/AsyncOxiaClientImpl.java b/client/src/main/java/io/streamnative/oxia/client/AsyncOxiaClientImpl.java
@@ -784,21 +784,21 @@ private void internalRangeScanMultiShards(
             RangeScanConsumer consumer) {
         final Set<Long> shardIds = shardManager.allShardIds();
         final RangeScanConsumer multiShardConsumer =
-                new ShardingRangeScanConsumer(shardIds.size(), consumer);
+                new SharedRangeScanConsumer(shardIds.size(), consumer);
         for (long shardId : shardIds) {
             internalShardRangeScan(
                     shardId, startKeyInclusive, endKeyExclusive, secondaryIndexName, multiShardConsumer);
         }
     }
 
-    static class ShardingRangeScanConsumer implements RangeScanConsumer {
+    static class SharedRangeScanConsumer implements RangeScanConsumer {
         private final RangeScanConsumer delegate;
 
         private int pendingCompletedRequests;
         private boolean completed = false;
         private Throwable completedException = null;
 
-        ShardingRangeScanConsumer(int shards, RangeScanConsumer delegate) {
+        SharedRangeScanConsumer(int shards, RangeScanConsumer delegate) {
             this.pendingCompletedRequests = shards;
             this.delegate = delegate;
         }

diff --git a/client/src/test/java/io/streamnative/oxia/client/AsyncOxiaClientImplTest.java b/client/src/test/java/io/streamnative/oxia/client/AsyncOxiaClientImplTest.java
@@ -584,7 +584,7 @@ void testShardShardRangeScanConsumer() {
         final AtomicInteger onCompletedCount = new AtomicInteger(0);
         final Supplier<RangeScanConsumer> newShardRangeScanConsumer =
                 () ->
-                        new AsyncOxiaClientImpl.ShardingRangeScanConsumer(
+                        new AsyncOxiaClientImpl.SharedRangeScanConsumer(
                                 5,
                                 new RangeScanConsumer() {
                                     @Override