Add first implementations of new JAX-RS 3.1 APIs

(cherry picked from commit 9134fa8)
aloubyansky · Sep 15, 2022 · 7bfb03f · 7bfb03f
1 parent 1ac7483
commit 7bfb03f
Show file tree

Hide file tree

Showing 2 changed files with 40 additions and 4 deletions.
diff --git a/...n/runtime/src/main/java/org/jboss/resteasy/reactive/common/jaxrs/RuntimeDelegateImpl.java b/...n/runtime/src/main/java/org/jboss/resteasy/reactive/common/jaxrs/RuntimeDelegateImpl.java
@@ -1,8 +1,10 @@
 package org.jboss.resteasy.reactive.common.jaxrs;
 
+import jakarta.ws.rs.SeBootstrap;
 import jakarta.ws.rs.core.Application;
 import jakarta.ws.rs.core.CacheControl;
 import jakarta.ws.rs.core.Cookie;
+import jakarta.ws.rs.core.EntityPart;
 import jakarta.ws.rs.core.EntityTag;
 import jakarta.ws.rs.core.Link;
 import jakarta.ws.rs.core.MediaType;
@@ -14,6 +16,7 @@
 import java.util.Date;
 import java.util.Locale;
 import java.util.ServiceLoader;
+import java.util.concurrent.CompletionStage;
 import org.jboss.resteasy.reactive.RestResponse;
 import org.jboss.resteasy.reactive.RestResponse.ResponseBuilder;
 import org.jboss.resteasy.reactive.common.core.ResponseBuilderFactory;
@@ -113,4 +116,30 @@ public <T> HeaderDelegate<T> createHeaderDelegate(Class<T> type) throws IllegalA
     public Link.Builder createLinkBuilder() {
         return new LinkBuilderImpl();
     }
+
+    @Override
+    public SeBootstrap.Configuration.Builder createConfigurationBuilder() {
+        // RR does not implement currently implement the bootstrapping API
+        throw new UnsupportedOperationException("Pending implementation");
+    }
+
+    @Override
+    public CompletionStage<SeBootstrap.Instance> bootstrap(Application application,
+            SeBootstrap.Configuration configuration) {
+        // RR does not implement currently implement the bootstrapping API
+        throw new UnsupportedOperationException("Pending implementation");
+    }
+
+    @Override
+    public CompletionStage<SeBootstrap.Instance> bootstrap(Class<? extends Application> aClass,
+            SeBootstrap.Configuration configuration) {
+        // RR does not implement currently implement the bootstrapping API
+        throw new UnsupportedOperationException("Pending implementation");
+    }
+
+    @Override
+    public EntityPart.Builder createEntityPartBuilder(String s) throws IllegalArgumentException {
+        // TODO: figure out how to implement this
+        throw new UnsupportedOperationException("Pending implementation");
+    }
 }
diff --git a/...er/runtime/src/main/java/org/jboss/resteasy/reactive/server/jaxrs/SseBroadcasterImpl.java b/...er/runtime/src/main/java/org/jboss/resteasy/reactive/server/jaxrs/SseBroadcasterImpl.java
@@ -60,13 +60,20 @@ private void checkClosed() {
     }
 
     @Override
-    public synchronized void close() {
+    public void close() {
+        close(true);
+    }
+
+    @Override
+    public synchronized void close(boolean cascading) {
         if (isClosed)
             return;
         isClosed = true;
-        for (SseEventSink sink : sinks) {
-            // this will in turn fire close events to our listeners
-            sink.close();
+        if (cascading) {
+            for (SseEventSink sink : sinks) {
+                // this will in turn fire close events to our listeners
+                sink.close();
+            }
         }
     }