14
14
public final class SwitchTransform <T , R > extends Flux <R > {
15
15
16
16
final Publisher <? extends T > source ;
17
- final BiFunction <T , Flux <? extends T >, Publisher <? extends R >> transformer ;
17
+ final BiFunction <T , Flux <T >, Publisher <? extends R >> transformer ;
18
18
19
- public SwitchTransform (Publisher <? extends T > source , BiFunction <T , Flux <? extends T >, Publisher <? extends R >> transformer ) {
19
+ public SwitchTransform (Publisher <? extends T > source , BiFunction <T , Flux <T >, Publisher <? extends R >> transformer ) {
20
20
this .source = Objects .requireNonNull (source , "source" );
21
21
this .transformer = Objects .requireNonNull (transformer , "transformer" );
22
22
}
@@ -28,7 +28,7 @@ public void subscribe(CoreSubscriber<? super R> actual) {
28
28
29
29
static final class SwitchTransformSubscriber <T , R > implements CoreSubscriber <T > {
30
30
final CoreSubscriber <? super R > actual ;
31
- final BiFunction <T , Flux <? extends T >, Publisher <? extends R >> transformer ;
31
+ final BiFunction <T , Flux <T >, Publisher <? extends R >> transformer ;
32
32
final DirectProcessor <T > processor = DirectProcessor .create ();
33
33
34
34
Subscription s ;
@@ -38,7 +38,7 @@ static final class SwitchTransformSubscriber<T, R> implements CoreSubscriber<T>
38
38
static final AtomicIntegerFieldUpdater <SwitchTransformSubscriber > ONCE =
39
39
AtomicIntegerFieldUpdater .newUpdater (SwitchTransformSubscriber .class , "once" );
40
40
41
- SwitchTransformSubscriber (CoreSubscriber <? super R > actual , BiFunction <T , Flux <? extends T >, Publisher <? extends R >> transformer ) {
41
+ SwitchTransformSubscriber (CoreSubscriber <? super R > actual , BiFunction <T , Flux <T >, Publisher <? extends R >> transformer ) {
42
42
this .actual = actual ;
43
43
this .transformer = transformer ;
44
44
}
0 commit comments