https://github.com/langchain4j/langchain4j/pull/2906

Author: dliubarskyi

langchain4j-http-client-spring-restclient/src/main/java/dev/langchain4j/http/client/spring/restclient/SpringRestClient.java

@@ -19,6 +19,7 @@
 import java.io.InputStream;
 import java.net.SocketTimeoutException;
 
+import static dev.langchain4j.http.client.sse.ServerSentEventListenerUtils.ignoringExceptions;
 import static dev.langchain4j.internal.Utils.getOrDefault;
 
 public class SpringRestClient implements HttpClient {
@@ -96,26 +97,30 @@ public void execute(HttpRequest request, ServerSentEventParser parser, ServerSen
 
                             if (!springResponse.getStatusCode().is2xxSuccessful()) {
                                 String body = springResponse.bodyTo(String.class);
-                                listener.onError(new HttpException(statusCode, body));
+
+                                HttpException exception = new HttpException(statusCode, body);
+                                ignoringExceptions(() -> listener.onError(exception));
                                 return null;
                             }
 
                             SuccessfulHttpResponse response = SuccessfulHttpResponse.builder()
                                     .statusCode(statusCode)
                                     .headers(springResponse.getHeaders())
                                     .build();
-                            listener.onOpen(response);
+                            ignoringExceptions(() -> listener.onOpen(response));
 
                             try (InputStream inputStream = springResponse.getBody()) {
                                 parser.parse(inputStream, listener);
-                                listener.onClose();
+                                ignoringExceptions(listener::onClose);
                             }
 
                             return null;
                         });
             } catch (Exception e) {
                 if (e.getCause() instanceof SocketTimeoutException) {
-                    listener.onError(new TimeoutException(e));
+                    ignoringExceptions(() -> listener.onError(new TimeoutException(e)));
+                } else {
+                    ignoringExceptions(() -> listener.onError(e));
                 }
             }
         });