blob: 8e06171cc02fdd40714e73997428fc00fb908c0a [file] [log] [blame]
Austin Schuh272c6132020-11-14 16:37:52 -08001// Copyright 2019 Google LLC
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7// https://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use super::{Reader, VectorReader};
16use std::iter::{DoubleEndedIterator, ExactSizeIterator, FusedIterator, Iterator};
17
18/// Iterates over a flexbuffer vector, typed vector, or map. Yields [Readers](struct.Reader.html).
19///
20/// If any error occurs, the Reader is defaulted to a Null flexbuffer Reader.
21pub struct ReaderIterator<'de> {
22 pub(super) reader: VectorReader<'de>,
23 pub(super) front: usize,
24 end: usize,
25}
26impl<'de> ReaderIterator<'de> {
27 pub(super) fn new(reader: VectorReader<'de>) -> Self {
28 let end = reader.len();
29 ReaderIterator {
30 reader,
31 front: 0,
32 end,
33 }
34 }
35}
36impl<'de> Iterator for ReaderIterator<'de> {
37 type Item = Reader<'de>;
38 fn next(&mut self) -> Option<Self::Item> {
39 if self.front < self.end {
40 let r = self.reader.idx(self.front);
41 self.front += 1;
42 Some(r)
43 } else {
44 None
45 }
46 }
47 fn size_hint(&self) -> (usize, Option<usize>) {
48 let remaining = self.end - self.front;
49 (remaining, Some(remaining))
50 }
51}
52impl<'de> DoubleEndedIterator for ReaderIterator<'de> {
53 fn next_back(&mut self) -> Option<Self::Item> {
54 if self.front < self.end {
55 self.end -= 1;
56 Some(self.reader.idx(self.end))
57 } else {
58 None
59 }
60 }
61}
62impl<'de> ExactSizeIterator for ReaderIterator<'de> {}
63impl<'de> FusedIterator for ReaderIterator<'de> {}