Modifications after some code review remarks

Signed-off-by: Franck LECUYER <[email protected]>

Author: FranckLecuyer

src/main/java/org/gridsuite/securityanalysis/server/service/SecurityAnalysisWorkerService.java

@@ -179,14 +179,13 @@ public Consumer<Flux<Message<String>>> consumeRun() {
                                 futures.remove(resultContext.getResultUuid());
                                 cancelComputationRequests.remove(resultContext.getResultUuid());
                                 runRequests.remove(resultContext.getResultUuid());
-                            })
-                            .doOnError(throwable -> {
-                                if (!(throwable instanceof CancellationException)) {
-                                    LOGGER.error("Exception in consumeRun", throwable);
-                                }
                             });
                 })
-                .onErrorContinue((t, r) -> LOGGER.error("Exception in consumeRun", t))
+                .onErrorContinue((t, r) -> {
+                    if (!(t instanceof CancellationException)) {
+                        LOGGER.error("Exception in consumeRun", t);
+                    }
+                })
                 .subscribe();
     }