diff --git a/rsocket-core/src/main/java/io/rsocket/internal/LimitableRequestPublisher.java b/rsocket-core/src/main/java/io/rsocket/internal/LimitableRequestPublisher.java
index dbf1ff3ec..00015321c 100755
--- a/rsocket-core/src/main/java/io/rsocket/internal/LimitableRequestPublisher.java
+++ b/rsocket-core/src/main/java/io/rsocket/internal/LimitableRequestPublisher.java
@@ -59,7 +59,7 @@ public void subscribe(CoreSubscriber<? super T> destination) {
     }
 
     destination.onSubscribe(new InnerSubscription());
-    source.subscribe(new InnerSubscriber<>(destination));
+    source.subscribe(new InnerSubscriber(destination));
   }
 
   public void increaseRequestLimit(long n) {
@@ -100,10 +100,10 @@ public void cancel() {
     }
   }
 
-  private class InnerSubscriber<T> implements Subscriber<T> {
+  private class InnerSubscriber implements Subscriber<T> {
     Subscriber<? super T> destination;
 
-    public InnerSubscriber(Subscriber<? super T> destination) {
+    private InnerSubscriber(Subscriber<? super T> destination) {
       this.destination = destination;
     }