Skip to content

Commit fbee9ca

Browse files
Fix concurrent fetch test
1 parent e56eafd commit fbee9ca

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

src/test/java/oracle/r2dbc/impl/OracleStatementImplTest.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2126,10 +2126,11 @@ public void testConcurrentFetch() {
21262126
.boxed()
21272127
.collect(Collectors.toList());
21282128

2129-
awaitMany(IntStream.range(0, publishers.length)
2129+
awaitOne(IntStream.range(0, publishers.length)
21302130
.mapToObj(i -> expected)
2131-
.collect(Collectors.toList()),
2132-
Flux.merge(fetchPublishers));
2131+
.collect(Collectors.toSet()),
2132+
Flux.merge(fetchPublishers)
2133+
.collect(Collectors.toSet()));
21332134
}
21342135
finally {
21352136
tryAwaitExecution(connection.createStatement(
@@ -2203,7 +2204,7 @@ public void testUsingWhenCancel() {
22032204
// drop table command executes. Set a DDL wait timeout to avoid a
22042205
// "Resource busy..." error from the database.
22052206
tryAwaitExecution(connection.createStatement(
2206-
"ALTER SESSION SET ddl_lock_wait_timeout=15"));
2207+
"ALTER SESSION SET ddl_lock_timeout=15"));
22072208
tryAwaitExecution(connection.createStatement(
22082209
"DROP TABLE testUsingWhenCancel"));
22092210
tryAwaitNone(connection.close());

0 commit comments

Comments
 (0)