File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
rsocket-core/src/main/java/io/rsocket/internal Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -59,7 +59,7 @@ public void subscribe(CoreSubscriber<? super T> destination) {
59
59
}
60
60
61
61
destination .onSubscribe (new InnerSubscription ());
62
- source .subscribe (new InnerSubscriber <> (destination ));
62
+ source .subscribe (new InnerSubscriber (destination ));
63
63
}
64
64
65
65
public void increaseRequestLimit (long n ) {
@@ -100,10 +100,10 @@ public void cancel() {
100
100
}
101
101
}
102
102
103
- private class InnerSubscriber < T > implements Subscriber <T > {
103
+ private class InnerSubscriber implements Subscriber <T > {
104
104
Subscriber <? super T > destination ;
105
105
106
- public InnerSubscriber (Subscriber <? super T > destination ) {
106
+ private InnerSubscriber (Subscriber <? super T > destination ) {
107
107
this .destination = destination ;
108
108
}
109
109
You can’t perform that action at this time.
0 commit comments