src/org/redkale/convert/ArrayDecoder.java

@@ -91,6 +91,7 @@ public class ArrayDecoder<T> implements Decodeable<Reader, T[]> {
             int startPosition = in.position();
             while (hasNext(in, member, startPosition, contentLength, first)) {
                 Reader itemReader = getItemReader(in, member, first);
+                if (itemReader == null) break;
                 result.add(readMemberValue(itemReader, member, first));
                 first = false;
             }

src/org/redkale/convert/CollectionDecoder.java

@@ -91,6 +91,7 @@ public class CollectionDecoder<T> implements Decodeable<Reader, Collection<T>> {
             int startPosition = in.position();
             while (hasNext(in, member, startPosition, contentLength, first)) {
                 Reader itemReader = getItemReader(in, member, first);
+                if (itemReader == null) break;
                 result.add(readMemberValue(itemReader, member, first));
                 first = false;
             }

src/org/redkale/convert/MapDecoder.java

@@ -104,6 +104,7 @@ public class MapDecoder<K, V> implements Decodeable<Reader, Map<K, V>> {
             int startPosition = in.position();
             while (hasNext(in, member, startPosition, contentLength, first)) {
                 Reader entryReader = getEntryReader(in, member, first);
+                if (entryReader == null) break;
                 K key = readKeyMember(entryReader, member, first);
                 entryReader.readBlank();
                 V value = readValueMember(entryReader, member, first);

src/org/redkale/convert/StreamDecoder.java

@@ -87,6 +87,7 @@ public class StreamDecoder<T> implements Decodeable<Reader, Stream<T>> {
             int startPosition = in.position();
             while (hasNext(in, member, startPosition, contentLength, first)) {
                 Reader itemReader = getItemReader(in, member, first);
+                if (itemReader == null) break;
                 result.add(readMemberValue(itemReader, member, first));
                 first = false;
             }