diff --git a/integration-tests/grpc-hibernate/src/test/java/com/example/grpc/hibernate/BlockingRawTest.java b/integration-tests/grpc-hibernate/src/test/java/com/example/grpc/hibernate/BlockingRawTest.java index 1d732a476598a..a024213ed09bf 100644 --- a/integration-tests/grpc-hibernate/src/test/java/com/example/grpc/hibernate/BlockingRawTest.java +++ b/integration-tests/grpc-hibernate/src/test/java/com/example/grpc/hibernate/BlockingRawTest.java @@ -6,6 +6,7 @@ import java.time.Duration; import java.util.ArrayList; import java.util.List; +import java.util.concurrent.CopyOnWriteArrayList; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Timeout; @@ -49,7 +50,7 @@ void shouldAdd() { .await().atMost(Duration.ofSeconds(5)); } - List actual = new ArrayList<>(); + List actual = new CopyOnWriteArrayList<>(); Multi all = client.getAll(EMPTY) .onFailure().invoke(th -> { System.out.println("Failed to read"); @@ -65,8 +66,8 @@ void shouldAdd() { @Timeout(TIMEOUT) void shouldAddViaBidi() { List expected = new ArrayList<>(); - List echoed = new ArrayList<>(); - List actual = new ArrayList<>(); + List echoed = new CopyOnWriteArrayList<>(); + List actual = new CopyOnWriteArrayList<>(); Multi request = Multi.createFrom().emitter( m -> {