extract sse response handling in a handler

Author: ryber

unirest/src/main/java/kong/unirest/core/java/JavaClient.java

@@ -170,13 +170,7 @@ public CompletableFuture<Void> sse(SseRequest request, SseListener listener) {
                 .build();
 
         return client.sendAsync(r, java.net.http.HttpResponse.BodyHandlers.ofLines())
-                .thenAccept(response -> {
-                    response.body().forEach(line -> {
-                        if (!line.isBlank()) {
-                            listener.onComment(line);
-                        }
-                    });
-                })
+                .thenAccept(new SseResponseHandler(listener))
                 .exceptionally(ex -> {
                     System.err.println("Error: " + ex.getMessage());
                     return null;

unirest/src/main/java/kong/unirest/core/java/SseResponseHandler.java

@@ -0,0 +1,24 @@
+package kong.unirest.core.java;
+
+import kong.unirest.core.SseListener;
+
+import java.net.http.HttpResponse;
+import java.util.function.Consumer;
+import java.util.stream.Stream;
+
+class SseResponseHandler implements Consumer<HttpResponse<Stream<String>>> {
+    private final SseListener listener;
+
+    public SseResponseHandler(SseListener listener) {
+        this.listener = listener;
+    }
+
+    @Override
+    public void accept(HttpResponse<Stream<String>> response) {
+            response.body().forEach(line -> {
+                if (!line.isBlank()) {
+                    listener.onComment(line);
+                }
+            });
+    }
+}