remove reactive

Author: eze210

modules/http-api/src/main/java/module-info.java

@@ -17,7 +17,6 @@
   // For the deprecated API methods still relying on org.mule.runtime.core.api.retry.policy.RetryPolicyTemplate
   requires org.mule.runtime.core;
   requires com.github.benmanes.caffeine;
-  requires org.reactivestreams;
 
   exports org.mule.runtime.http.api;
   exports org.mule.runtime.http.api.client;

modules/http-api/src/main/java/org/mule/runtime/http/api/client/HttpClient.java

@@ -12,7 +12,6 @@
 import org.mule.runtime.http.api.client.ws.WebSocketCallback;
 import org.mule.runtime.http.api.domain.message.request.HttpRequest;
 import org.mule.runtime.http.api.domain.message.response.HttpResponse;
-import org.mule.runtime.http.api.domain.sse.ServerSentEvent;
 import org.mule.runtime.http.api.ws.WebSocket;
 
 import java.io.IOException;
@@ -21,8 +20,6 @@
 import java.util.concurrent.TimeoutException;
 import java.util.function.BiConsumer;
 
-import org.reactivestreams.Publisher;
-
 /**
  * Object that sends an HTTP request, and returns the response. Notice it must be started to be used and stopped to be disposed
  * properly. Blocking and non-blocking options are available to execute requests. To extends it's functionality and not depend on
@@ -171,12 +168,6 @@ default CompletableFuture<WebSocket> openWebSocket(HttpRequest request,
     throw new UnsupportedOperationException("WebSockets are only supported in Enterprise Edition");
   }
 
-  default Publisher<ServerSentEvent> consumeServerSentEvents(HttpRequest request,
-                                                             HttpRequestOptions requestOptions,
-                                                             String streamId) {
-    throw new UnsupportedOperationException("Server-sent Events are not supported");
-  }
-
   default ServerSentEventSource sseSource(String url) {
     throw new UnsupportedOperationException("Server-sent Events are not supported");
   }