File tree Expand file tree Collapse file tree 4 files changed +11
-12
lines changed
core/src/test/java/com/datastax/dse/driver/internal/core/cql/reactive
mapper-runtime/src/test/java/com/datastax/dse/driver/api/mapper/reactive Expand file tree Collapse file tree 4 files changed +11
-12
lines changed Original file line number Diff line number Diff line change @@ -81,7 +81,8 @@ public List<T> getElements() {
8181 }
8282
8383 public void awaitTermination () {
84- Uninterruptibles .awaitUninterruptibly (latch , 1 , TimeUnit .MINUTES );
85- if (latch .getCount () > 0 ) fail ("subscriber not terminated" );
84+ if (!Uninterruptibles .awaitUninterruptibly (latch , 1 , TimeUnit .MINUTES )) {
85+ fail ("subscriber not terminated" );
86+ }
8687 }
8788}
Original file line number Diff line number Diff line change 4545 <groupId >com.google.errorprone</groupId >
4646 <artifactId >error_prone_annotations</artifactId >
4747 </exclusion >
48- <exclusion >
49- <groupId >com.google.j2objc</groupId >
50- <artifactId >j2objc-annotations</artifactId >
51- </exclusion >
52- <exclusion >
53- <groupId >org.codehaus.mojo</groupId >
54- <artifactId >animal-sniffer-annotations</artifactId >
55- </exclusion >
5648 </exclusions >
5749 </dependency >
5850 <dependency >
7870 <includes >
7971 <include >org.apache.cassandra:java-driver-guava-shaded</include >
8072 <include >com.google.guava:guava</include >
73+ <include >com.google.guava:failureaccess</include >
74+ <include >com.google.j2objc:j2objc-annotations</include >
8175 </includes >
8276 </artifactSet >
8377 <relocations >
Original file line number Diff line number Diff line change 1717 */
1818package com .datastax .dse .driver .api .mapper .reactive ;
1919
20+ import static org .assertj .core .api .Fail .fail ;
21+
2022import com .datastax .oss .driver .shaded .guava .common .util .concurrent .Uninterruptibles ;
2123import edu .umd .cs .findbugs .annotations .NonNull ;
2224import edu .umd .cs .findbugs .annotations .Nullable ;
@@ -70,6 +72,8 @@ public List<T> getElements() {
7072 }
7173
7274 public void awaitTermination () {
73- Uninterruptibles .awaitUninterruptibly (latch , 1 , TimeUnit .MINUTES );
75+ if (!Uninterruptibles .awaitUninterruptibly (latch , 1 , TimeUnit .MINUTES )) {
76+ fail ("subscriber not terminated" );
77+ }
7478 }
7579}
Original file line number Diff line number Diff line change 114114 <!-- Version of Guava used in shaded module and for integration tests. -->
115115 <groupId >com.google.guava</groupId >
116116 <artifactId >guava</artifactId >
117- <version >25 .1-jre</version >
117+ <version >33.3 .1-jre</version >
118118 </dependency >
119119 <dependency >
120120 <groupId >com.typesafe</groupId >
You can’t perform that action at this time.
0 commit comments