Polishing

Author: mirromutth

src/main/java/io/asyncer/r2dbc/mysql/internal/util/FluxEnvelope.java

@@ -57,7 +57,7 @@ public void subscribe(CoreSubscriber<? super ByteBuf> actual) {
         if (cumulate) {
             this.source.subscribe(new CumulateEnvelopeSubscriber(actual, alloc, size, start));
         } else {
-            this.source.subscribe(new DirectEnvelopeSubscriber(actual, alloc, size, start));
+            this.source.subscribe(new DirectEnvelopeSubscriber(actual, alloc, start));
         }
     }
 }
@@ -68,19 +68,15 @@ final class DirectEnvelopeSubscriber implements CoreSubscriber<ByteBuf>, Scannab
 
     private final ByteBufAllocator alloc;
 
-    private final int size;
-
     private boolean done;
 
     private Subscription s;
 
     private int envelopeId;
 
-    DirectEnvelopeSubscriber(CoreSubscriber<? super ByteBuf> actual, ByteBufAllocator alloc, int size,
-        int start) {
+    DirectEnvelopeSubscriber(CoreSubscriber<? super ByteBuf> actual, ByteBufAllocator alloc, int start) {
         this.actual = actual;
         this.alloc = alloc;
-        this.size = size;
         this.envelopeId = start;
     }
 
@@ -155,7 +151,6 @@ public Context currentContext() {
     }
 
     @Override
-    @SuppressWarnings("rawtypes")
     public Object scanUnsafe(Attr key) {
         if (key == Attr.PARENT) {
             return this.s;
@@ -322,7 +317,6 @@ public Context currentContext() {
     }
 
     @Override
-    @SuppressWarnings("rawtypes")
     public Object scanUnsafe(Attr key) {
         if (key == Attr.PARENT) {
             return this.s;

src/main/java/io/asyncer/r2dbc/mysql/message/client/SubsequenceClientMessage.java

@@ -17,7 +17,8 @@
 package io.asyncer.r2dbc.mysql.message.client;
 
 /**
- * An abstraction of {@link ClientMessage} considers as a subsequence of a request message.
+ * An abstraction of {@link ClientMessage} that considers as a subsequence of responses from a request from
+ * the server.
  * <p>
  * All encoded buffers will not be cumulated.
  */