This commit is contained in:
@@ -78,13 +78,14 @@ public class BsonByteBufferWriter extends BsonWriter {
|
|||||||
ByteBuffer buffer = this.buffers[index];
|
ByteBuffer buffer = this.buffers[index];
|
||||||
if (!buffer.hasRemaining()) {
|
if (!buffer.hasRemaining()) {
|
||||||
buffer.flip();
|
buffer.flip();
|
||||||
buffer = supplier.get();
|
buffer = supplier.get();
|
||||||
this.buffers = Utility.append(this.buffers, buffer);
|
this.buffers = Utility.append(this.buffers, buffer);
|
||||||
this.index++;
|
this.index++;
|
||||||
}
|
}
|
||||||
int len = buffer.remaining();
|
int len = buffer.remaining();
|
||||||
int size = 0;
|
int size = 0;
|
||||||
while (len < byteLength) {
|
while (len < byteLength) {
|
||||||
|
buffer = supplier.get();
|
||||||
this.buffers = Utility.append(this.buffers, buffer);
|
this.buffers = Utility.append(this.buffers, buffer);
|
||||||
len += buffer.remaining();
|
len += buffer.remaining();
|
||||||
size++;
|
size++;
|
||||||
|
|||||||
Reference in New Issue
Block a user