small fix

Consensys · Jan 11, 2025 · 1335519 · 1335519
1 parent fba9f8c
commit 1335519
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...ain/java/tech/pegasys/teku/beacon/sync/forward/multipeer/chains/ThrottlingSyncSource.java b/...ain/java/tech/pegasys/teku/beacon/sync/forward/multipeer/chains/ThrottlingSyncSource.java
@@ -68,13 +68,13 @@ public SafeFuture<Void> requestBlocksByRange(
       final UInt64 startSlot,
       final UInt64 count,
       final RpcResponseListener<SignedBeaconBlock> listener) {
-    final RpcResponseListenerWithCount<SignedBeaconBlock> listenerWithCount =
-        new RpcResponseListenerWithCount<>(listener);
     return blocksRateTracker
         .approveObjectsRequest(count.longValue())
         .map(
             requestApproval -> {
               LOG.debug("Sending request for {} blocks", count);
+              final RpcResponseListenerWithCount<SignedBeaconBlock> listenerWithCount =
+                  new RpcResponseListenerWithCount<>(listener);
               return delegate
                   .requestBlocksByRange(startSlot, count, listenerWithCount)
                   .alwaysRun(
@@ -97,8 +97,6 @@ public SafeFuture<Void> requestBlocksByRange(
   @Override
   public SafeFuture<Void> requestBlobSidecarsByRange(
       final UInt64 startSlot, final UInt64 count, final RpcResponseListener<BlobSidecar> listener) {
-    final RpcResponseListenerWithCount<BlobSidecar> listenerWithCount =
-        new RpcResponseListenerWithCount<>(listener);
     long blobSidecarsCount =
         maybeMaxBlobsPerBlock
             .map(maxBlobsPerBlock -> maxBlobsPerBlock * count.longValue())
@@ -108,6 +106,8 @@ public SafeFuture<Void> requestBlobSidecarsByRange(
         .map(
             requestApproval -> {
               LOG.debug("Sending request for ~ {} blob sidecars", blobSidecarsCount);
+              final RpcResponseListenerWithCount<BlobSidecar> listenerWithCount =
+                  new RpcResponseListenerWithCount<>(listener);
               return delegate
                   .requestBlobSidecarsByRange(startSlot, count, listenerWithCount)
                   .alwaysRun(