Sync with QPid

acogoluegnes · acogoluegnes · commit 311be6166eef · 2024-06-03T15:37:08.000+02:00
diff --git a/src/main/qpid/org/apache/qpid/protonj2/buffer/netty/ProtonBufferToNetty5Adapter.java b/src/main/qpid/org/apache/qpid/protonj2/buffer/netty/ProtonBufferToNetty5Adapter.java
@@ -968,12 +968,12 @@ public T first() {
 
         @SuppressWarnings("unchecked")
         @Override
-        public T next() {
+        public <N extends Next & BufferComponent> N next() {
             if (current != null) {
                 current = accessor.next();
             }
 
-            return current != null ? (T) this : null;
+            return current != null ? (N) this : null;
         }
 
         @Override
@@ -1067,6 +1067,8 @@ public BufferComponent skipWritableBytes(int byteCount) {
             current.advanceWriteOffset(byteCount);
             return this;
         }
+
+
     }
 
     private final static class ProtonByteCursorAdapter implements ByteCursor {

Original file line number	Diff line number	Diff line change
`@@ -968,12 +968,12 @@ public T first() {`
`968`	`968`
`969`	`969`	`@SuppressWarnings("unchecked")`
`970`	`970`	`@Override`
`971`		`- public T next() {`
	`971`	`+ public <N extends Next & BufferComponent> N next() {`
`972`	`972`	`if (current != null) {`
`973`	`973`	`current = accessor.next();`
`974`	`974`	`}`
`975`	`975`
`976`		`- return current != null ? (T) this : null;`
	`976`	`+ return current != null ? (N) this : null;`
`977`	`977`	`}`
`978`	`978`
`979`	`979`	`@Override`
`@@ -1067,6 +1067,8 @@ public BufferComponent skipWritableBytes(int byteCount) {`
`1067`	`1067`	`current.advanceWriteOffset(byteCount);`
`1068`	`1068`	`return this;`
`1069`	`1069`	`}`
	`1070`	`+`
	`1071`	`+`
`1070`	`1072`	`}`
`1071`	`1073`
`1072`	`1074`	`private final static class ProtonByteCursorAdapter implements ByteCursor {`