mirror of
https://github.com/google/flatbuffers.git
synced 2026-06-02 20:15:34 +00:00
4174c10e7a
* feature/rust-tokio-bytes added feature name for tokio-bytes * Added flexbuffer implementation, TODO: typecast to avoid recurse * Converted codebase to utilize FlexBuffer implementation, need to resolve deserialization issues * Added todo for lifetime issue, may use &'de [u8] for deserializer instead of current method * Added proper &[u8] implementation * Removed unused struct * Added experimental fix to get_slice * Added experimental fix to get_slice * Avoided lifetime issues via ref structs, need to check if this hurts peformance * Updated deserializer implementation to allow for borrowed data from Reader struct * Fixed bug with str * Removed unnecessary generic parameter * Added unsafe to avoid lifetime complaints, current tests pass, need to review alternatives to unsafe * Opinionated: Removed bytes crate as this implementation could be done in a separate crate * Cleaned up flatbuffer * Fixed sample / example * Resolved PR feedback, need to resolve issues with tests * Cleaned up FlexBuffer trait to be an auto impl * Removed TODO * Reverted Deserializer to only support &'de [u8] * Cleaned up / renamed function for clarification * Renamed FlexBuffer -> InternalBuffer for clarification on it's purpose * Fixed issue with key bytes * resolved issues with broken tests, confirming this is a breaking change * Removed FIXME that's solved by splitting String and Key variants * Implemented associated types approach * Fixed backward slice logic * Fixed MapReader compile error * Added from_buffer for deserialization, removed function since it's only needed for deserialization * Removed dead code * Cleaned up buffer, removed AsRef in favor of Deref * Renamed Buffer::as_str -> Buffer::buffer_str * Minor cleanup * Updated documentation, need to fix tests * Removed unnecessary & * Removed unused lifetime * removed unnecessary as_ref * Minor optimization wrap-up * resolved issue with Clone * Added test to verify no deep-copy * Added for optimization * Updated to use empty fn instead of default * Updated comments / test name - plus the 0.3.0 version bump * comment
68 lines
2.0 KiB
Rust
68 lines
2.0 KiB
Rust
// Copyright 2019 Google LLC
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// https://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
use crate::{Buffer, Reader, VectorReader};
|
|
use std::iter::{DoubleEndedIterator, ExactSizeIterator, FusedIterator, Iterator};
|
|
|
|
/// Iterates over a flexbuffer vector, typed vector, or map. Yields [Readers](struct.Reader.html).
|
|
///
|
|
/// If any error occurs, the Reader is defaulted to a Null flexbuffer Reader.
|
|
pub struct ReaderIterator<B> {
|
|
pub(super) reader: VectorReader<B>,
|
|
pub(super) front: usize,
|
|
end: usize,
|
|
}
|
|
|
|
impl<B: Buffer> ReaderIterator<B> {
|
|
pub(super) fn new(reader: VectorReader<B>) -> Self {
|
|
let end = reader.len();
|
|
ReaderIterator {
|
|
reader,
|
|
front: 0,
|
|
end,
|
|
}
|
|
}
|
|
}
|
|
|
|
impl<B: Buffer> Iterator for ReaderIterator<B> {
|
|
type Item = Reader<B>;
|
|
fn next(&mut self) -> Option<Self::Item> {
|
|
if self.front < self.end {
|
|
let r = self.reader.idx(self.front);
|
|
self.front += 1;
|
|
Some(r)
|
|
} else {
|
|
None
|
|
}
|
|
}
|
|
fn size_hint(&self) -> (usize, Option<usize>) {
|
|
let remaining = self.end - self.front;
|
|
(remaining, Some(remaining))
|
|
}
|
|
}
|
|
|
|
impl<B: Buffer> DoubleEndedIterator for ReaderIterator<B> {
|
|
fn next_back(&mut self) -> Option<Self::Item> {
|
|
if self.front < self.end {
|
|
self.end -= 1;
|
|
Some(self.reader.idx(self.end))
|
|
} else {
|
|
None
|
|
}
|
|
}
|
|
}
|
|
|
|
impl<B: Buffer> ExactSizeIterator for ReaderIterator<B> {}
|
|
impl<B: Buffer> FusedIterator for ReaderIterator<B> {}
|