Fix wireInboundDelay behaviour

harmony-dev · Mar 11, 2019 · cdbed35 · cdbed35
1 parent 33bb4ca
commit cdbed35
Showing 1 changed file with 2 additions and 4 deletions.
diff --git 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());
       }
     }
   }