Apply minor polish to reactive client classes

quarkusio · Apr 12, 2021 · 0f935d3 · 0f935d3
1 parent 5607a7e
commit 0f935d3
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/...ve/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java b/...ve/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/...ent/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/SseEventSourceImpl.java b/...ent/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;