From 633605394e50b432a4eefaa9f90f2ac39162a2f2 Mon Sep 17 00:00:00 2001
From: Georgios Andrianakis <geoand@gmail.com>
Date: Mon, 12 Apr 2021 12:52:01 +0300
Subject: [PATCH] Apply minor polish to reactive client classes

---
 .../resteasy/reactive/client/impl/MultiInvoker.java    |  4 ++--
 .../reactive/client/impl/SseEventSourceImpl.java       | 10 +++++-----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java
index e7fcd50e42e4f..b6cd2aabd79b5 100644
--- a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java
+++ b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java
@@ -17,7 +17,7 @@
 
 public class MultiInvoker extends AbstractRxInvoker<Multi<?>> {
 
-    private WebTargetImpl target;
+    private final WebTargetImpl target;
 
     public MultiInvoker(WebTargetImpl target) {
         this.target = target;
@@ -44,7 +44,7 @@ static class MultiRequest<R> {
 
         private final AtomicReference<Runnable> onCancel = new AtomicReference<>();
 
-        private MultiEmitter<? super R> emitter;
+        private final MultiEmitter<? super R> emitter;
 
         private static final Runnable CLEARED = () -> {
         };
diff --git a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/SseEventSourceImpl.java b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/SseEventSourceImpl.java
index 3c0732f04f021..87f525ff3a5be 100644
--- a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/SseEventSourceImpl.java
+++ b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/SseEventSourceImpl.java
@@ -21,17 +21,17 @@ public class SseEventSourceImpl implements SseEventSource, Handler<Long> {
     private TimeUnit reconnectUnit;
     private long reconnectDelay;
 
-    private WebTargetImpl webTarget;
+    private final WebTargetImpl webTarget;
     // this tracks user request to open/close
     private volatile boolean isOpen;
     // this tracks whether we have a connection open
     private volatile boolean isInProgress;
 
-    private List<Consumer<InboundSseEvent>> consumers = new ArrayList<>();
-    private List<Consumer<Throwable>> errorListeners = new ArrayList<>();
-    private List<Runnable> completionListeners = new ArrayList<>();
+    private final List<Consumer<InboundSseEvent>> consumers = new ArrayList<>();
+    private final List<Consumer<Throwable>> errorListeners = new ArrayList<>();
+    private final List<Runnable> completionListeners = new ArrayList<>();
     private HttpConnection connection;
-    private SseParser sseParser;
+    private final SseParser sseParser;
     private long timerId = -1;
     private boolean receivedClientClose;