undo all changes to see if tests run through

Signed-off-by: Robrecht Cannoodt <[email protected]>

Author: rcannood

modules/nextflow/src/main/groovy/nextflow/Session.groovy

@@ -1148,17 +1148,23 @@ class Session implements ISession {
     private static <T> void notifyEvent(List<T> observers, Consumer<T> action) {
         for ( int i=0; i<observers.size(); i++) {
             final observer = observers.get(i)
-            CompletableFuture.runAsync(new Runnable() {
-                @Override
-                void run() {
-                    try {
-                        action.accept(observer)
-                    }
-                    catch ( Throwable e ) {
-                        log.debug(e.getMessage(), e)
-                    }
-                }
-            })
+            // CompletableFuture.runAsync(new Runnable() {
+            //     @Override
+            //     void run() {
+            //         try {
+            //             action.accept(observer)
+            //         }
+            //         catch ( Throwable e ) {
+            //             log.debug(e.getMessage(), e)
+            //         }
+            //     }
+            // })
+            try {
+                action.accept(observer)
+            }
+            catch ( Throwable e ) {
+                log.debug(e.getMessage(), e)
+            }
         }
     }
 

modules/nextflow/src/test/groovy/nextflow/SessionTest.groovy

@@ -463,41 +463,41 @@ class SessionTest extends Specification {
 
     }
 
-    def 'test notifyEvent is asynchronous'() {
-        given:
-        def events = []
-        def latch = new java.util.concurrent.CountDownLatch(2)
-        def observer1 = new nextflow.trace.TraceObserverV2() {
-            @Override
-            void onFlowBegin() {
-                Thread.sleep(50) // Simulate slow observer
-                events << 'observer1'
-                latch.countDown()
-            }
-        }
-        def observer2 = new nextflow.trace.TraceObserverV2() {
-            @Override
-            void onFlowBegin() {
-                events << 'observer2'
-                latch.countDown()
-            }
-        }
+    // def 'test notifyEvent is asynchronous'() {
+    //     given:
+    //     def events = []
+    //     def latch = new java.util.concurrent.CountDownLatch(2)
+    //     def observer1 = new nextflow.trace.TraceObserverV2() {
+    //         @Override
+    //         void onFlowBegin() {
+    //             Thread.sleep(50) // Simulate slow observer
+    //             events << 'observer1'
+    //             latch.countDown()
+    //         }
+    //     }
+    //     def observer2 = new nextflow.trace.TraceObserverV2() {
+    //         @Override
+    //         void onFlowBegin() {
+    //             events << 'observer2'
+    //             latch.countDown()
+    //         }
+    //     }
 
-        def session = new Session()
-        session.@observersV2 = [observer1, observer2]
+    //     def session = new Session()
+    //     session.@observersV2 = [observer1, observer2]
 
-        when:
-        def startTime = System.currentTimeMillis()
-        session.notifyFlowBegin()
-        def notifyTime = System.currentTimeMillis() - startTime
-        latch.await(1, java.util.concurrent.TimeUnit.SECONDS)
-        def completeTime = System.currentTimeMillis() - startTime
+    //     when:
+    //     def startTime = System.currentTimeMillis()
+    //     session.notifyFlowBegin()
+    //     def notifyTime = System.currentTimeMillis() - startTime
+    //     latch.await(1, java.util.concurrent.TimeUnit.SECONDS)
+    //     def completeTime = System.currentTimeMillis() - startTime
 
-        then:
-        notifyTime < 50 // Should return quickly without waiting for observers
-        completeTime >= 50 // But observers should complete
-        events.size() == 2
-        events.contains('observer1')
-        events.contains('observer2')
-    }
+    //     then:
+    //     notifyTime < 50 // Should return quickly without waiting for observers
+    //     completeTime >= 50 // But observers should complete
+    //     events.size() == 2
+    //     events.contains('observer1')
+    //     events.contains('observer2')
+    // }
 }