From e1cc445d119aaebf1df1f9e9c90c49f7c2a24039 Mon Sep 17 00:00:00 2001 From: Chris Vest Date: Wed, 28 Apr 2021 12:27:03 +0200 Subject: [PATCH] The CompositeBuffer.compose methods must return CompositeBuffer instead of Buffer --- src/main/java/io/netty/buffer/api/CompositeBuffer.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/io/netty/buffer/api/CompositeBuffer.java b/src/main/java/io/netty/buffer/api/CompositeBuffer.java index bf8b6fc..28c4a66 100644 --- a/src/main/java/io/netty/buffer/api/CompositeBuffer.java +++ b/src/main/java/io/netty/buffer/api/CompositeBuffer.java @@ -147,7 +147,7 @@ public final class CompositeBuffer extends RcSupport im * @throws IllegalArgumentException if the given buffers have an inconsistent * {@linkplain Buffer#order() byte order}. */ - public static Buffer compose(BufferAllocator allocator, Buffer... bufs) { + public static CompositeBuffer compose(BufferAllocator allocator, Buffer... bufs) { Stream bufferStream = Arrays.stream(bufs) .map(buf -> buf.acquire()); // Increments reference counts. return new CompositeBuffer(allocator, filterExternalBufs(bufferStream), COMPOSITE_DROP, false); @@ -181,7 +181,7 @@ public final class CompositeBuffer extends RcSupport im * will be closed and descarded, respectively. */ @SafeVarargs - public static Buffer compose(BufferAllocator allocator, Send... sends) { + public static CompositeBuffer compose(BufferAllocator allocator, Send... sends) { Buffer[] bufs = new Buffer[sends.length]; IllegalStateException ise = null; for (int i = 0; i < sends.length; i++) { @@ -212,7 +212,7 @@ public final class CompositeBuffer extends RcSupport im * {@link #ensureWritable(int)} calls. * @return A composite buffer that has no components, and has a capacity of zero. */ - public static Buffer compose(BufferAllocator allocator) { + public static CompositeBuffer compose(BufferAllocator allocator) { return new CompositeBuffer(allocator, EMPTY_BUFFER_ARRAY, COMPOSITE_DROP, false); }