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 81cb6fe commit d7e0feeCopy full SHA for d7e0fee
driver-embedded/src/main/com/mongodb/embedded/client/EmbeddedInternalConnection.java
@@ -41,6 +41,7 @@
41
import org.bson.ByteBufNIO;
42
import org.bson.codecs.Decoder;
43
44
+import java.nio.Buffer;
45
import java.nio.ByteBuffer;
46
import java.util.ArrayList;
47
import java.util.Collections;
@@ -162,9 +163,8 @@ public void write(final List<ByteBuf> buffers) {
162
163
@Override
164
public ByteBuf read(final int numBytes) {
165
ByteBuffer slice = curResponse.slice();
- slice.limit(numBytes);
166
- curResponse.position(curResponse.position() + numBytes);
167
-
+ ((Buffer) slice).limit(numBytes);
+ ((Buffer) curResponse).position(((Buffer)curResponse).position() + numBytes);
168
return new ByteBufNIO(slice);
169
}
170
0 commit comments