Merge tag '0.12.1-RC4' into develop

0.12.1-RC4

Author: robertroeser

gradle.properties

@@ -11,5 +11,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-
-version=0.12.1-RC4-SNAPSHOT
+version=0.12.1-RC4

rsocket-core/src/main/java/io/rsocket/buffer/TupleByteBuffs.java renamed to rsocket-core/src/main/java/io/rsocket/buffer/TupleByteBuf.java

@@ -4,9 +4,9 @@
 import io.netty.buffer.ByteBufAllocator;
 import java.util.Objects;
 
-public abstract class TupleByteBuffs {
+public abstract class TupleByteBuf {
 
-  private TupleByteBuffs() {}
+  private TupleByteBuf() {}
 
   public static ByteBuf of(ByteBuf one, ByteBuf two) {
     return of(ByteBufAllocator.DEFAULT, one, two);

rsocket-core/src/main/java/io/rsocket/frame/DataAndMetadataFlyweight.java

@@ -3,7 +3,7 @@
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;
 import io.netty.buffer.Unpooled;
-import io.rsocket.buffer.TupleByteBuffs;
+import io.rsocket.buffer.TupleByteBuf;
 
 class DataAndMetadataFlyweight {
   public static final int FRAME_LENGTH_MASK = 0xFFFFFF;
@@ -33,11 +33,11 @@ private static int decodeLength(final ByteBuf byteBuf) {
 
   static ByteBuf encodeOnlyMetadata(
       ByteBufAllocator allocator, final ByteBuf header, ByteBuf metadata) {
-    return TupleByteBuffs.of(allocator, header, metadata);
+    return TupleByteBuf.of(allocator, header, metadata);
   }
 
   static ByteBuf encodeOnlyData(ByteBufAllocator allocator, final ByteBuf header, ByteBuf data) {
-    return TupleByteBuffs.of(allocator, header, data);
+    return TupleByteBuf.of(allocator, header, data);
   }
 
   static ByteBuf encode(
@@ -46,7 +46,7 @@ static ByteBuf encode(
     int length = metadata.readableBytes();
     encodeLength(header, length);
 
-    return TupleByteBuffs.of(allocator, header, metadata, data);
+    return TupleByteBuf.of(allocator, header, metadata, data);
   }
 
   static ByteBuf metadataWithoutMarking(ByteBuf byteBuf, boolean hasMetadata) {

rsocket-core/src/main/java/io/rsocket/frame/FrameLengthFlyweight.java

@@ -2,7 +2,7 @@
 
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;
-import io.rsocket.buffer.TupleByteBuffs;
+import io.rsocket.buffer.TupleByteBuf;
 
 /**
  * Some transports like TCP aren't framed, and require a length. This is used by DuplexConnections
@@ -35,7 +35,7 @@ private static int decodeLength(final ByteBuf byteBuf) {
   public static ByteBuf encode(ByteBufAllocator allocator, int length, ByteBuf frame) {
     ByteBuf buffer = allocator.buffer();
     encodeLength(buffer, length);
-    return TupleByteBuffs.of(allocator, buffer, frame);
+    return TupleByteBuf.of(allocator, buffer, frame);
   }
 
   public static int length(ByteBuf byteBuf) {