Merge pull request #14354 from stuartwdouglas/test-thread-safety

Fix flakey RESTEasy reactive test
quarkusio · Jan 18, 2021 · fefa67c · fefa67c
2 parents 07d887a + 97ecec8
commit fefa67c
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/...loyment/src/test/java/io/quarkus/resteasy/reactive/server/test/stream/StreamTestCase.java b/...loyment/src/test/java/io/quarkus/resteasy/reactive/server/test/stream/StreamTestCase.java
@@ -2,9 +2,9 @@
 
 import java.net.URI;
 import java.time.Duration;
-import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
@@ -133,8 +133,8 @@ public void testSse() throws InterruptedException {
         WebTarget target = client.target(uri.toString() + "stream/sse");
         try (SseEventSource sse = SseEventSource.target(target).build()) {
             CountDownLatch latch = new CountDownLatch(1);
-            List<Throwable> errors = new ArrayList<>();
-            List<String> results = new ArrayList<>();
+            List<Throwable> errors = new CopyOnWriteArrayList<>();
+            List<String> results = new CopyOnWriteArrayList<>();
             sse.register(event -> {
                 results.add(event.readData());
             }, error -> {
@@ -155,8 +155,8 @@ public void testSseThrows() throws InterruptedException {
         WebTarget target = client.target(uri.toString() + "stream/sse/throws");
         try (SseEventSource sse = SseEventSource.target(target).build()) {
             CountDownLatch latch = new CountDownLatch(1);
-            List<Throwable> errors = new ArrayList<>();
-            List<String> results = new ArrayList<>();
+            List<Throwable> errors = new CopyOnWriteArrayList<>();
+            List<String> results = new CopyOnWriteArrayList<>();
             sse.register(event -> {
                 results.add(event.readData());
             }, error -> {