[#317] sendUnsolicitedNotification can fail on client disconnect with (…

…#320) OnErrorNotImplementedException
OpenIdentityPlatform · Jan 16, 2024 · dd18411 · dd18411
1 parent ab9e136
commit dd18411
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/LDAPServerFilter.java b/opendj-grizzly/src/main/java/org/forgerock/opendj/grizzly/LDAPServerFilter.java
@@ -84,6 +84,7 @@
 import com.forgerock.reactive.ReactiveHandler;
 import com.forgerock.reactive.Stream;
 
+import io.reactivex.exceptions.OnErrorNotImplementedException;
 import io.reactivex.internal.util.BackpressureHelper;
 
 /**
@@ -635,15 +636,21 @@ public void completed(Object result) {
             return newCompletable(new Completable.Emitter() {
                 @Override
                 public void subscribe(final Completable.Subscriber s) throws Exception {
-                    promise.thenOnResult(new ResultHandler<Boolean>() {
+                	promise.thenOnResult(new ResultHandler<Boolean>() {
                         @Override
                         public void handleResult(Boolean result) {
                             s.onComplete();
                         }
                     }).thenOnException(new ExceptionHandler<Exception>() {
                         @Override
                         public void handleException(Exception exception) {
-                            s.onError(exception);
+                            try {
+                            	 s.onError(exception);
+                            } catch (Throwable t) {
+                                if (!(t instanceof OnErrorNotImplementedException)) {
+                                    throw t;
+                                }
+                            }
                         }
                     }).thenOnRuntimeException(new RuntimeExceptionHandler() {
                         @Override
@@ -653,6 +660,7 @@ public void handleRuntimeException(RuntimeException exception) {
                     });
                 }
             });
+
         }
     }
 }