Add a new test from deprecation and fix the properties for the versions in the BOM.

bom/bom/pom.xml

@@ -25,22 +25,22 @@
             <dependency>
                 <groupId>dev.resteasy.netty</groupId>
                 <artifactId>resteasy-netty-embedded-server</artifactId>
-                <version>${project.version</version>
+                <version>${project.version}</version>
             </dependency>
             <dependency>
                 <groupId>dev.resteasy.netty</groupId>
                 <artifactId>resteasy-netty-embedded-server-cdi</artifactId>
-                <version>${project.version</version>
+                <version>${project.version}</version>
             </dependency>
             <dependency>
                 <groupId>dev.resteasy.netty</groupId>
                 <artifactId>resteasy-embedded-server-reactor</artifactId>
-                <version>${project.version</version>
+                <version>${project.version}</version>
             </dependency>
             <dependency>
                 <groupId>dev.resteasy.netty</groupId>
                 <artifactId>resteasy-reactor-netty-client</artifactId>
-                <version>${project.version</version>
+                <version>${project.version}</version>
             </dependency>
         </dependencies>
     </dependencyManagement>

embedded-server-reactor/pom.xml

@@ -113,6 +113,11 @@
             <artifactId>junit-jupiter-api</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>dev.resteasy.netty</groupId>
+            <artifactId>resteasy-reactor-netty-client</artifactId>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.mockito</groupId>
             <artifactId>mockito-core</artifactId>

embedded-server-reactor/src/test/java/org/jboss/resteasy/plugins/server/reactor/netty/Async.java

@@ -0,0 +1,19 @@
+/*
+ * Copyright The RESTEasy Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package org.jboss.resteasy.plugins.server.reactor.netty;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Target({ ElementType.PARAMETER, ElementType.METHOD, ElementType.FIELD })
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface Async {
+
+}

embedded-server-reactor/src/test/java/org/jboss/resteasy/plugins/server/reactor/netty/ReactorInjector.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright The RESTEasy Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package org.jboss.resteasy.plugins.server.reactor.netty;
+
+import java.lang.annotation.Annotation;
+import java.lang.reflect.Type;
+
+import jakarta.ws.rs.ext.Provider;
+
+import org.jboss.resteasy.spi.ContextInjector;
+
+import reactor.core.publisher.Mono;
+
+@Provider
+public class ReactorInjector implements ContextInjector<Mono<Integer>, Integer> {
+
+    @Override
+    public Mono<Integer> resolve(Class<? extends Mono<Integer>> rawType, Type genericType,
+            Annotation[] annotations) {
+        boolean async = false;
+        for (Annotation annotation : annotations) {
+            if (annotation.annotationType() == Async.class)
+                async = true;
+        }
+        if (!async)
+            return Mono.just(24);
+        return Mono.create(emitter -> {
+            new Thread(() -> {
+                try {
+                    Thread.sleep(1000);
+                } catch (InterruptedException e) {
+                    emitter.error(e);
+                    return;
+                }
+                emitter.success(42);
+            }).start();
+        });
+    }
+
+}

embedded-server-reactor/src/test/java/org/jboss/resteasy/plugins/server/reactor/netty/ReactorResource.java

@@ -0,0 +1,60 @@
+/*
+ * Copyright The RESTEasy Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package org.jboss.resteasy.plugins.server.reactor.netty;
+
+import java.time.Duration;
+import java.util.concurrent.atomic.AtomicInteger;
+
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.PathParam;
+import jakarta.ws.rs.Produces;
+import jakarta.ws.rs.core.Context;
+import jakarta.ws.rs.core.MediaType;
+
+import org.jboss.resteasy.annotations.Stream;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Path("/")
+public class ReactorResource {
+    static final AtomicInteger monoEndpointCounter = new AtomicInteger(0);
+
+    @Path("mono")
+    @GET
+    public Mono<String> mono() {
+        monoEndpointCounter.incrementAndGet();
+        return Mono.just("got it");
+    }
+
+    @Produces(MediaType.APPLICATION_JSON)
+    @Path("flux")
+    @GET
+    @Stream
+    public Flux<String> flux() {
+        return Flux.just("one", "two");
+    }
+
+    @Path("injection")
+    @GET
+    public Mono<Integer> injection(@Context Integer value) {
+        return Mono.just(value);
+    }
+
+    @Path("injection-async")
+    @GET
+    public Mono<Integer> injectionAsync(@Async @Context Integer value) {
+        return Mono.just(value);
+    }
+
+    @Path("delay/{secs}")
+    @GET
+    public Mono<String> delay(@PathParam("secs") int delay) {
+        return Mono.just("I delayed for " + delay + " seconds.")
+                .delayElement(Duration.ofSeconds(delay));
+    }
+}