diff --git a/wire/src/main/java/org/ethereum/beacon/wire/LocalWireHub.java b/wire/src/main/java/org/ethereum/beacon/wire/LocalWireHub.java
index 15ab944cc..2c09d0d1b 100644
--- a/wire/src/main/java/org/ethereum/beacon/wire/LocalWireHub.java
+++ b/wire/src/main/java/org/ethereum/beacon/wire/LocalWireHub.java
@@ -71,8 +71,7 @@ public Publisher<BeaconBlock> inboundBlocksStream() {
         return blocks;
       } else {
         return Flux.from(blocks)
-            .delayElements(Duration.ofMillis(inboundDelay))
-            .publishOn(schedulers.reactorEvents());
+            .delayElements(Duration.ofMillis(inboundDelay), schedulers.reactorEvents());
       }
     }
 
@@ -82,8 +81,7 @@ public Publisher<Attestation> inboundAttestationsStream() {
         return attestations;
       } else {
         return Flux.from(attestations)
-            .delayElements(Duration.ofMillis(inboundDelay))
-            .publishOn(schedulers.reactorEvents());
+            .delayElements(Duration.ofMillis(inboundDelay), schedulers.reactorEvents());
       }
     }
   }