diff --git a/libp2p/src/main/java/io/libp2p/protocol/circuit/CircuitHopProtocol.java b/libp2p/src/main/java/io/libp2p/protocol/circuit/CircuitHopProtocol.java index be2be179d..db8d73126 100644 --- a/libp2p/src/main/java/io/libp2p/protocol/circuit/CircuitHopProtocol.java +++ b/libp2p/src/main/java/io/libp2p/protocol/circuit/CircuitHopProtocol.java @@ -315,11 +315,15 @@ public void onMessage(@NotNull Stream stream, Circuit.HopMessage msg) { new CircuitStopProtocol.StopRemover()); // connect these streams with time + bytes enforcement - fromRequestor.pushHandler(new InboundTrafficLimitHandler(resv.maxBytes)); + if(resv.maxBytes > 0){ + fromRequestor.pushHandler(new InboundTrafficLimitHandler(resv.maxBytes)); + } fromRequestor.pushHandler( new TotalTimeoutHandler( Duration.of(resv.durationSeconds, ChronoUnit.SECONDS))); - toTarget.pushHandler(new InboundTrafficLimitHandler(resv.maxBytes)); + if(resv.maxBytes > 0){ + toTarget.pushHandler(new InboundTrafficLimitHandler(resv.maxBytes)); + } toTarget.pushHandler( new TotalTimeoutHandler( Duration.of(resv.durationSeconds, ChronoUnit.SECONDS)));