Polish PublisherResponseHandler

Author: geoand

independent-projects/resteasy-reactive/server/runtime/src/main/java/org/jboss/resteasy/reactive/server/handlers/PublisherResponseHandler.java

@@ -312,32 +312,32 @@ private boolean requiresChunkedStream(MediaType mediaType) {
                 || mediaType.isCompatible(RestMediaType.APPLICATION_STREAM_JSON_TYPE);
     }
 
+    @SuppressWarnings("rawtypes")
     private void handleChunkedStreaming(ResteasyReactiveRequestContext requestContext, Publisher<?> result, boolean json) {
         long demand = 1L;
-        if (result instanceof RestMulti.SyncRestMulti) {
-            RestMulti.SyncRestMulti rest = (RestMulti.SyncRestMulti) result;
+        if (result instanceof RestMulti.SyncRestMulti rest) {
             demand = rest.getDemand();
         }
         result.subscribe(
                 new StreamingMultiSubscriber(requestContext, streamingResponseCustomizers, result, json, demand, false));
     }
 
+    @SuppressWarnings("rawtypes")
     private void handleStreaming(ResteasyReactiveRequestContext requestContext, Publisher<?> result, boolean json) {
         long demand = 1L;
         boolean encodeAsJsonArray = true;
-        if (result instanceof RestMulti.SyncRestMulti) {
-            RestMulti.SyncRestMulti rest = (RestMulti.SyncRestMulti) result;
+        if (result instanceof RestMulti.SyncRestMulti rest) {
             demand = rest.getDemand();
             encodeAsJsonArray = rest.encodeAsJsonArray();
         }
         result.subscribe(new StreamingMultiSubscriber(requestContext, streamingResponseCustomizers, result, json, demand,
                 encodeAsJsonArray));
     }
 
+    @SuppressWarnings("rawtypes")
     private void handleSse(ResteasyReactiveRequestContext requestContext, Publisher<?> result) {
         long demand;
-        if (result instanceof RestMulti.SyncRestMulti) {
-            RestMulti.SyncRestMulti rest = (RestMulti.SyncRestMulti) result;
+        if (result instanceof RestMulti.SyncRestMulti rest) {
             demand = rest.getDemand();
         } else {
             demand = 1L;

independent-projects/resteasy-reactive/server/runtime/src/main/java/org/jboss/resteasy/reactive/server/jaxrs/SseEventSinkImpl.java

@@ -14,7 +14,7 @@
 public class SseEventSinkImpl implements SseEventSink {
 
     public static final byte[] EMPTY_BUFFER = new byte[0];
-    private ResteasyReactiveRequestContext context;
+    private final ResteasyReactiveRequestContext context;
     private SseBroadcasterImpl broadcaster;
     private boolean closed;