From 96ea154176ef04bf59c9a041b190d0cdc6df7186 Mon Sep 17 00:00:00 2001 From: HenrikJannsen Date: Wed, 23 Nov 2022 19:53:12 -0500 Subject: [PATCH] Rename delegate to outputStream Signed-off-by: HenrikJannsen --- .../bisq/network/p2p/network/ProtoOutputStream.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/p2p/src/main/java/bisq/network/p2p/network/ProtoOutputStream.java b/p2p/src/main/java/bisq/network/p2p/network/ProtoOutputStream.java index 4c313a535f..9a15e0df19 100644 --- a/p2p/src/main/java/bisq/network/p2p/network/ProtoOutputStream.java +++ b/p2p/src/main/java/bisq/network/p2p/network/ProtoOutputStream.java @@ -33,11 +33,11 @@ import javax.annotation.concurrent.NotThreadSafe; class ProtoOutputStream { private static final Logger log = LoggerFactory.getLogger(ProtoOutputStream.class); - private final OutputStream delegate; + private final OutputStream outputStream; private final Statistic statistic; - ProtoOutputStream(OutputStream delegate, Statistic statistic) { - this.delegate = delegate; + ProtoOutputStream(OutputStream outputStream, Statistic statistic) { + this.outputStream = outputStream; this.statistic = statistic; } @@ -52,7 +52,7 @@ class ProtoOutputStream { void onConnectionShutdown() { try { - delegate.close(); + outputStream.close(); } catch (Throwable t) { log.error("Failed to close connection", t); } @@ -61,8 +61,8 @@ class ProtoOutputStream { private void writeEnvelopeOrThrow(NetworkEnvelope envelope) throws IOException { long ts = System.currentTimeMillis(); protobuf.NetworkEnvelope proto = envelope.toProtoNetworkEnvelope(); - proto.writeDelimitedTo(delegate); - delegate.flush(); + proto.writeDelimitedTo(outputStream); + outputStream.flush(); long duration = System.currentTimeMillis() - ts; if (duration > 10000) { log.info("Sending {} to peer took {} sec.", envelope.getClass().getSimpleName(), duration / 1000d);