We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0b98ab0 commit d574294Copy full SHA for d574294
net.lecousin.core/src/main/java/net/lecousin/framework/io/buffering/ByteBuffersIO.java
@@ -325,11 +325,13 @@ protected void closeResources(SynchronizationPoint<Exception> ondone) {
325
326
@Override
327
public int writeSync(ByteBuffer buffer) {
328
- addBuffer(buffer.array(), buffer.position(), buffer.remaining());
+ addBuffer(buffer.array(), buffer.arrayOffset() + buffer.position(), buffer.remaining());
329
pos = totalSize;
330
bufferIndex = buffers.size();
331
bufferPos = 0;
332
- return buffer.remaining();
+ int len = buffer.remaining();
333
+ buffer.position(buffer.position() + len);
334
+ return len;
335
}
336
337
0 commit comments