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() {
81
81
}
82
82
83
83
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
+ }
86
87
}
87
88
}
Original file line number Diff line number Diff line change 45
45
<groupId >com.google.errorprone</groupId >
46
46
<artifactId >error_prone_annotations</artifactId >
47
47
</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 >
56
48
</exclusions >
57
49
</dependency >
58
50
<dependency >
78
70
<includes >
79
71
<include >org.apache.cassandra:java-driver-guava-shaded</include >
80
72
<include >com.google.guava:guava</include >
73
+ <include >com.google.guava:failureaccess</include >
74
+ <include >com.google.j2objc:j2objc-annotations</include >
81
75
</includes >
82
76
</artifactSet >
83
77
<relocations >
Original file line number Diff line number Diff line change 17
17
*/
18
18
package com .datastax .dse .driver .api .mapper .reactive ;
19
19
20
+ import static org .assertj .core .api .Fail .fail ;
21
+
20
22
import com .datastax .oss .driver .shaded .guava .common .util .concurrent .Uninterruptibles ;
21
23
import edu .umd .cs .findbugs .annotations .NonNull ;
22
24
import edu .umd .cs .findbugs .annotations .Nullable ;
@@ -70,6 +72,8 @@ public List<T> getElements() {
70
72
}
71
73
72
74
public void awaitTermination () {
73
- Uninterruptibles .awaitUninterruptibly (latch , 1 , TimeUnit .MINUTES );
75
+ if (!Uninterruptibles .awaitUninterruptibly (latch , 1 , TimeUnit .MINUTES )) {
76
+ fail ("subscriber not terminated" );
77
+ }
74
78
}
75
79
}
Original file line number Diff line number Diff line change 114
114
<!-- Version of Guava used in shaded module and for integration tests. -->
115
115
<groupId >com.google.guava</groupId >
116
116
<artifactId >guava</artifactId >
117
- <version >25 .1-jre</version >
117
+ <version >33.3 .1-jre</version >
118
118
</dependency >
119
119
<dependency >
120
120
<groupId >com.typesafe</groupId >
You can’t perform that action at this time.
0 commit comments