From cdbed351b118aa7bd04af6ff2a3136f15f752eec Mon Sep 17 00:00:00 2001
From: Anton Nashatyrev <anton.nashatyrev@gmail.com>
Date: Mon, 11 Mar 2019 19:28:58 +0300
Subject: [PATCH] Fix wireInboundDelay behaviour

---
 .../main/java/org/ethereum/beacon/wire/LocalWireHub.java    | 6 ++----
 1 file changed, 2 insertions(+), 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
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());
       }
     }
   }