File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
hibernate-reactive-core/src/test/java/org/hibernate/reactive Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change 1616import java .util .concurrent .Executors ;
1717import java .util .stream .IntStream ;
1818
19+ import org .junit .jupiter .api .Disabled ;
1920import org .junit .jupiter .api .Test ;
2021
2122import org .jboss .logging .Logger ;
3334import static java .util .stream .Stream .concat ;
3435import static org .assertj .core .api .Assertions .assertThat ;
3536
37+ @ Disabled
3638public class CancelSignalTest extends BaseReactiveTest {
3739 private static final Logger LOG = Logger .getLogger ( CancelSignalTest .class );
3840
@@ -50,7 +52,7 @@ public void cleanupConnectionWhenCancelSignal(VertxTestContext context) {
5052
5153 ExecutorService withSessionExecutor = Executors .newFixedThreadPool ( executeSize );
5254 // Create some jobs that are going to be cancelled asynchronously
53- CompletableFuture [] withSessionFutures = IntStream
55+ CompletableFuture <?> [] withSessionFutures = IntStream
5456 .range ( 0 , executeSize )
5557 .mapToObj ( i -> runAsync (
5658 () -> {
@@ -76,7 +78,7 @@ public void cleanupConnectionWhenCancelSignal(VertxTestContext context) {
7678
7779 // Create jobs that are going to cancel the previous ones
7880 ExecutorService cancelExecutor = Executors .newFixedThreadPool ( executeSize );
79- CompletableFuture [] cancelFutures = IntStream
81+ CompletableFuture <?> [] cancelFutures = IntStream
8082 .range ( 0 , executeSize )
8183 .mapToObj ( i -> runAsync (
8284 () -> {
You can’t perform that action at this time.
0 commit comments