File tree Expand file tree Collapse file tree 4 files changed +13
-9
lines changed
reactor-core/src/test/java/reactor/core/publisher Expand file tree Collapse file tree 4 files changed +13
-9
lines changed Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright (c) 2015-2022 VMware Inc. or its affiliates, All Rights Reserved.
2
+ * Copyright (c) 2015-2024 VMware Inc. or its affiliates, All Rights Reserved.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
27
27
import java .util .concurrent .atomic .AtomicReference ;
28
28
29
29
import org .assertj .core .api .Assertions ;
30
+ import org .assertj .core .api .InstanceOfAssertFactories ;
30
31
import org .junit .jupiter .api .Test ;
31
32
import org .reactivestreams .Subscriber ;
32
33
import org .reactivestreams .Subscription ;
@@ -864,7 +865,7 @@ void inners() {
864
865
sink .subscribe (scannable );
865
866
866
867
assertThat (sink .inners ())
867
- .asList ( )
868
+ .asInstanceOf ( InstanceOfAssertFactories . LIST )
868
869
.as ("after subscriptions" )
869
870
.hasSize (2 )
870
871
.extracting (l -> (Object ) ((NextProcessor .NextInner <?>) l ).actual )
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright (c) 2020-2022 VMware Inc. or its affiliates, All Rights Reserved.
2
+ * Copyright (c) 2020-2024 VMware Inc. or its affiliates, All Rights Reserved.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
21
21
import java .util .concurrent .atomic .AtomicBoolean ;
22
22
import java .util .concurrent .atomic .AtomicReference ;
23
23
24
+ import org .assertj .core .api .InstanceOfAssertFactories ;
24
25
import org .junit .jupiter .api .Test ;
25
26
import org .reactivestreams .Subscriber ;
26
27
@@ -168,7 +169,7 @@ void inners() {
168
169
sink .asMono ().subscribe (scannable );
169
170
170
171
assertThat (sink .inners ())
171
- .asList ( )
172
+ .asInstanceOf ( InstanceOfAssertFactories . LIST )
172
173
.as ("after subscriptions" )
173
174
.hasSize (2 )
174
175
.extracting (l -> (Object ) ((SinkEmptyMulticast .VoidInner <?>) l ).actual )
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright (c) 2021-2022 VMware Inc. or its affiliates, All Rights Reserved.
2
+ * Copyright (c) 2021-2024 VMware Inc. or its affiliates, All Rights Reserved.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
21
21
import java .util .concurrent .atomic .AtomicReference ;
22
22
23
23
import org .assertj .core .api .Assertions ;
24
+ import org .assertj .core .api .InstanceOfAssertFactories ;
24
25
import org .junit .jupiter .api .Test ;
25
26
import org .junit .jupiter .api .Timeout ;
26
27
import org .reactivestreams .Subscriber ;
@@ -321,7 +322,7 @@ void inners() {
321
322
sink .subscribe (scannable );
322
323
323
324
assertThat (sink .inners ())
324
- .asList ( )
325
+ .asInstanceOf ( InstanceOfAssertFactories . LIST )
325
326
.as ("after subscriptions" )
326
327
.hasSize (2 )
327
328
.extracting (l -> (Object ) ((SinkOneMulticast .Inner <?>) l ).actual ())
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright (c) 2020-2021 VMware Inc. or its affiliates, All Rights Reserved.
2
+ * Copyright (c) 2020-2024 VMware Inc. or its affiliates, All Rights Reserved.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
18
18
19
19
import java .time .Duration ;
20
20
21
+ import org .assertj .core .api .InstanceOfAssertFactories ;
21
22
import org .junit .jupiter .api .Test ;
22
23
23
24
import reactor .core .CoreSubscriber ;
@@ -166,12 +167,12 @@ void inners() {
166
167
sink2 .asFlux ().subscribe (scannable );
167
168
168
169
assertThat (sink1 .inners ())
169
- .asList ( )
170
+ .asInstanceOf ( InstanceOfAssertFactories . LIST )
170
171
.as ("after notScannable subscription" )
171
172
.containsExactly (Scannable .from ("NOT SCANNABLE" ));
172
173
173
174
assertThat (sink2 .inners ())
174
- .asList ( )
175
+ .asInstanceOf ( InstanceOfAssertFactories . LIST )
175
176
.as ("after scannable subscription" )
176
177
.containsExactly (scannable );
177
178
}
You can’t perform that action at this time.
0 commit comments