25
25
import org .junit .jupiter .api .Nested ;
26
26
import org .junit .jupiter .api .Test ;
27
27
import org .reactivestreams .Publisher ;
28
+ import reactor .core .CoreSubscriber ;
28
29
import reactor .core .publisher .Flux ;
29
- import reactor .core .publisher .FluxProcessor ;
30
30
import reactor .core .publisher .Mono ;
31
31
32
32
import static org .assertj .core .api .Assertions .assertThat ;
@@ -45,16 +45,16 @@ class ReactiveAdapterRegistryTests {
45
45
void getAdapterForReactiveSubType () {
46
46
47
47
ReactiveAdapter adapter1 = getAdapter (Flux .class );
48
- ReactiveAdapter adapter2 = getAdapter (FluxProcessor .class );
48
+ ReactiveAdapter adapter2 = getAdapter (ExtendedFlux .class );
49
49
50
50
assertThat (adapter2 ).isSameAs (adapter1 );
51
51
52
52
this .registry .registerReactiveType (
53
- ReactiveTypeDescriptor .multiValue (FluxProcessor .class , FluxProcessor ::empty ),
54
- o -> (FluxProcessor <?, ?>) o ,
55
- FluxProcessor ::from );
53
+ ReactiveTypeDescriptor .multiValue (ExtendedFlux .class , ExtendedFlux ::empty ),
54
+ o -> (ExtendedFlux < ?>) o ,
55
+ ExtendedFlux ::from );
56
56
57
- ReactiveAdapter adapter3 = getAdapter (FluxProcessor .class );
57
+ ReactiveAdapter adapter3 = getAdapter (ExtendedFlux .class );
58
58
59
59
assertThat (adapter3 ).isNotNull ();
60
60
assertThat (adapter3 ).isNotSameAs (adapter1 );
@@ -363,4 +363,12 @@ private ReactiveAdapter getAdapter(Class<?> reactiveType) {
363
363
return adapter ;
364
364
}
365
365
366
+
367
+ private static class ExtendedFlux <T > extends Flux <T > {
368
+
369
+ @ Override
370
+ public void subscribe (CoreSubscriber actual ) {
371
+ throw new UnsupportedOperationException ();
372
+ }
373
+ }
366
374
}
0 commit comments