jdk-sandbox: comparison test/jdk/jdk/jfr/api/consumer/streaming/TestLatestEvent.java

equal deleted inserted replaced

-:e6feb2874fa6
+:141412e96b12
 System.out.println("All empty chunks created");
 // Create an event in a segment, typically the first.
 NotLatestEvent notLatest = new NotLatestEvent();
 notLatest.commit();
 try (EventStream s = EventStream.openRepository()) {
+// Wait for next segment
+// to prevent flush to prevent NotLatest to be included
+awaitFlush(r);
 System.out.println("EventStream opened");
-awaitFlush(r); // ensure that NotLatest is included
-s.startAsync();
 AtomicBoolean foundLatest = new AtomicBoolean();
-System.out.println("Added onEvent handler");
 s.onEvent(event -> {
 String name = event.getEventType().getName();
 System.out.println("Found event " + name);
 foundLatest.set(name.equals("Latest"));
 s.close();
 });
+System.out.println("Added onEvent handler");
+s.startAsync();
+// wait for next segment
+awaitFlush(s);
 // Emit the latest event
 LatestEvent latest = new LatestEvent();
 latest.commit();
 System.out.println("Latest event emitted");
 System.out.println("Waiting for termination");
 }
 }
 }
 }
-private static void awaitFlush(RecordingStream r) throws InterruptedException {
+private static void awaitFlush(EventStream stream) throws InterruptedException {
 CountDownLatch latch = new CountDownLatch(1);
 System.out.println("Waiting for flush...");
-r.onFlush(() -> {
+final Runnable l =  () -> {
 System.out.println("Flush arrived!");
 latch.countDown();
-});
+};
+stream.onFlush(l);
 latch.await();
+stream.remove(l);
 }
 }