V8

BasePractice · Nov 1, 2024 · 14f2c5b · 14f2c5b
1 parent 00f748f
commit 14f2c5b
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/vol8/src/main/java/ru/mifi/practice/vol8/User.java b/vol8/src/main/java/ru/mifi/practice/vol8/User.java
@@ -29,11 +29,15 @@ public static void main(String[] args) {
         byte[] bytes = output.toByteArray();
         try (BsonReader reader = new BsonBinaryReader(new Bson.BsonInputStream(
             new ByteArrayInputStream(bytes)))) {
-            reader.readStartDocument();
             boolean reading = true;
             while (reading) {
                 BsonType type = reader.readBsonType();
                 switch (type) {
+                    case DOCUMENT: {
+                        reader.readStartDocument();
+                        System.out.println("Start document");
+                        break;
+                    }
                     case END_OF_DOCUMENT: {
                         System.out.println("End of document");
                         reading = false;

diff --git a/vol8/src/main/java/ru/mifi/practice/vol8/streaming/Bson.java b/vol8/src/main/java/ru/mifi/practice/vol8/streaming/Bson.java
@@ -14,6 +14,7 @@
 
 public final class Bson {
     public static final class BsonInputStream implements BsonInput {
+        private static final int READ_LIMIT = 4096;
         private static final String[] ONE_BYTE_ASCII_STRINGS = new String[Byte.MAX_VALUE + 1];
 
         static {
@@ -122,7 +123,7 @@ public ObjectId readObjectId() {
         @Override
         public String readCString() {
             int mark = getPosition();
-            stream.mark(1024);
+            stream.mark(READ_LIMIT);
             skipCString();
             int size = getPosition();
             stream.reset();
@@ -182,11 +183,12 @@ private void ensureAvailable(final int bytesNeeded) {
 
     private static final class PosBufferedInputStream extends BufferedInputStream {
 
-        public PosBufferedInputStream(InputStream in) {
+        private PosBufferedInputStream(InputStream in) {
             super(in);
         }
 
-        public int getPosition() {
+        @SuppressWarnings("PMD.UnusedPrivateMethod")
+        private int getPosition() {
             return pos;
         }
     }