refactor: replace RestSseElementType with RestStreamElementType

quarkusio/quarkus#20908 quarkusio/quarkus#13663
manusa · Jun 7, 2023 · b147bb1 · b147bb1
1 parent b30f4ee
commit b147bb1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/main/java/com/marcnuri/yakc/quickstarts/dashboard/pod/PodResource.java b/src/main/java/com/marcnuri/yakc/quickstarts/dashboard/pod/PodResource.java
@@ -23,7 +23,7 @@
 import io.smallrye.mutiny.Multi;
 import io.smallrye.mutiny.converters.multi.MultiRxConverters;
 import io.vertx.core.http.HttpServerResponse;
-import org.jboss.resteasy.reactive.RestSseElementType;
+import org.jboss.resteasy.reactive.RestStreamElementType;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -94,7 +94,7 @@ public Pod update(@PathParam("namespace") String namespace, @PathParam("name") S
 
   @GET
   @Produces(MediaType.SERVER_SENT_EVENTS)
-  @RestSseElementType(MediaType.APPLICATION_JSON) // TODO Replaced by RestStreamElementType in next Quarkus version bump
+  @RestStreamElementType(MediaType.APPLICATION_JSON)
   @Path("/{namespace}/{name}/logs/{container}")
   public void getLogs(
     @Context HttpServerResponse response, @Context Sse sse, @Context SseEventSink sseEventSink,

diff --git a/src/main/java/com/marcnuri/yakc/quickstarts/dashboard/watch/WatchResource.java b/src/main/java/com/marcnuri/yakc/quickstarts/dashboard/watch/WatchResource.java
@@ -21,7 +21,7 @@
 import io.quarkus.runtime.ShutdownEvent;
 import io.quarkus.runtime.annotations.RegisterForReflection;
 import io.vertx.core.http.HttpServerResponse;
-import org.jboss.resteasy.reactive.RestSseElementType;
+import org.jboss.resteasy.reactive.RestStreamElementType;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -60,7 +60,7 @@ void onShutdown(@Observes ShutdownEvent event) {
 
   @GET
   @Produces(MediaType.SERVER_SENT_EVENTS)
-  @RestSseElementType(MediaType.APPLICATION_JSON) // TODO Replaced by RestStreamElementType in next Quarkus version bump
+  @RestStreamElementType(MediaType.APPLICATION_JSON)
   public void get(@Context HttpServerResponse response, @Context Sse sse, @Context SseEventSink sseEventSink) {
     watchService.newWatch(response).runSubscriptionOn(subscribeExecutor).subscribe().with(we -> {
       try {