File tree Expand file tree Collapse file tree 1 file changed +7
-4
lines changed
sdk/trace-shaded-deps/src/test/java/io/opentelemetry/sdk/trace/internal Expand file tree Collapse file tree 1 file changed +7
-4
lines changed Original file line number Diff line number Diff line change @@ -43,7 +43,7 @@ void drain_ArrayBlockingQueue() {
43
43
void drain_MessagePassingQueue () {
44
44
// Arrange
45
45
batch .add ("Test3" );
46
- Queue <String > queue = new MpscArrayQueue <> (10 );
46
+ Queue <String > queue = JcTools . newFixedSizeQueue (10 );
47
47
queue .add ("Test1" );
48
48
queue .add ("Test2" );
49
49
@@ -58,7 +58,7 @@ void drain_MessagePassingQueue() {
58
58
@ Test
59
59
void drain_MaxBatch () {
60
60
// Arrange
61
- Queue <String > queue = new MpscArrayQueue <> (10 );
61
+ Queue <String > queue = JcTools . newFixedSizeQueue (10 );
62
62
queue .add ("Test1" );
63
63
queue .add ("Test2" );
64
64
@@ -79,7 +79,10 @@ void newFixedSize_MpscQueue() {
79
79
Queue <Object > objects = JcTools .newFixedSizeQueue (capacity );
80
80
81
81
// Assert
82
- assertThat (objects ).isInstanceOf (MpscArrayQueue .class );
82
+ assertThat (objects )
83
+ .satisfiesAnyOf (
84
+ queue -> assertThat (queue ).isInstanceOf (MpscArrayQueue .class ),
85
+ queue -> assertThat (queue ).isInstanceOf (ArrayBlockingQueue .class ));
83
86
}
84
87
85
88
@ Test
@@ -92,7 +95,7 @@ void capacity_MpscQueue() {
92
95
long queueSize = JcTools .capacity (queue );
93
96
94
97
// Assert
95
- assertThat (queueSize ).isGreaterThan (capacity );
98
+ assertThat (queueSize ).isGreaterThanOrEqualTo (capacity );
96
99
}
97
100
98
101
@ Test
You can’t perform that action at this time.
0 commit comments