pub trait FallibleStreamingIterator {
type Item: ?Sized;
type Error;
Show 21 methods
fn advance(&mut self) -> Result<(), Self::Error>;
fn get(&self) -> Option<&Self::Item>;
fn next(&mut self) -> Result<Option<&Self::Item>, Self::Error> { ... }
fn size_hint(&self) -> (usize, Option<usize>) { ... }
fn all<F>(&mut self, f: F) -> Result<bool, Self::Error>
where
F: FnMut(&Self::Item) -> bool,
{ ... }
fn any<F>(&mut self, f: F) -> Result<bool, Self::Error>
where
F: FnMut(&Self::Item) -> bool,
{ ... }
fn by_ref(&mut self) -> &mut Self { ... }
fn count(self) -> Result<usize, Self::Error> { ... }
fn filter<F>(self, f: F) -> Filter<Self, F>
where
F: FnMut(&Self::Item) -> bool,
{ ... }
fn find<F>(&mut self, f: F) -> Result<Option<&Self::Item>, Self::Error>
where
F: FnMut(&Self::Item) -> bool,
{ ... }
fn for_each<F>(self, f: F) -> Result<(), Self::Error>
where
F: FnMut(&Self::Item),
{ ... }
fn fuse(self) -> Fuse<Self> { ... }
fn map<F, B>(self, f: F) -> Map<Self, F, B>
where
F: FnMut(&Self::Item) -> B,
{ ... }
fn map_ref<F, B>(self, f: F) -> MapRef<Self, F>
where
F: Fn(&Self::Item) -> &B,
B: ?Sized,
{ ... }
fn map_err<F, B>(self, f: F) -> MapErr<Self, F>
where
F: Fn(Self::Error) -> B,
{ ... }
fn nth(&mut self, n: usize) -> Result<Option<&Self::Item>, Self::Error> { ... }
fn position<F>(&mut self, f: F) -> Result<Option<usize>, Self::Error>
where
F: FnMut(&Self::Item) -> bool,
{ ... }
fn skip(self, n: usize) -> Skip<Self> { ... }
fn skip_while<F>(self, f: F) -> SkipWhile<Self, F>
where
F: FnMut(&Self::Item) -> bool,
{ ... }
fn take(self, n: usize) -> Take<Self> { ... }
fn take_while<F>(self, f: F) -> TakeWhile<Self, F>
where
F: FnMut(&Self::Item) -> bool,
{ ... }
}
io_json
only.Expand description
A fallible, streaming iterator.
Required Associated Types
Required Methods
Advances the iterator to the next position.
Iterators start just before the first item, so this method should be called before get
when iterating.
The behavior of calling this method after get
has returned None
, or after this method
has returned an error is unspecified.
Provided Methods
Advances the iterator, returning the next element.
The default implementation simply calls advance
followed by get
.
Returns bounds on the number of remaining elements in the iterator.
Determines if all elements of the iterator satisfy a predicate.
Determines if any elements of the iterator satisfy a predicate.
Borrows an iterator, rather than consuming it.
This is useful to allow the application of iterator adaptors while still retaining ownership of the original adaptor.
Returns the number of remaining elements in the iterator.
Returns an iterator which filters elements by a predicate.
Returns the first element of the iterator which satisfies a predicate.
Calls a closure on each element of an iterator.
Returns an iterator which is well-behaved at the beginning and end of iteration.
Returns an iterator which applies a transform to elements.
Returns an iterator which applies a transform to elements.
Unlike map
, the the closure provided to this method returns a reference into the original
value.
Returns an iterator that applies a transform to errors.
Returns the nth
element of the iterator.
Returns the position of the first element matching a predicate.
Returns an iterator which skips the first sequence of elements matching a predicate.
Returns an iterator which only returns the first n
elements.
Implementations on Foreign Types
sourceimpl<'a, I> FallibleStreamingIterator for &'a mut I where
I: FallibleStreamingIterator + ?Sized,
impl<'a, I> FallibleStreamingIterator for &'a mut I where
I: FallibleStreamingIterator + ?Sized,
type Item = <I as FallibleStreamingIterator>::Item
type Error = <I as FallibleStreamingIterator>::Error
fn advance(&mut self) -> Result<(), <I as FallibleStreamingIterator>::Error>
fn get(&self) -> Option<&<I as FallibleStreamingIterator>::Item>
fn size_hint(&self) -> (usize, Option<usize>)
fn next(
&mut self
) -> Result<Option<&<I as FallibleStreamingIterator>::Item>, <I as FallibleStreamingIterator>::Error>
impl<I, O, F, E, II> FallibleStreamingIterator for Decompressor<I, O, F, E, II> where
I: Compressed,
O: Decompressed,
E: Error,
II: Iterator<Item = Result<I, E>>,
F: Fn(I, &mut Vec<u8, Global>) -> Result<O, E>,
impl<I, O, F, E, II> FallibleStreamingIterator for Decompressor<I, O, F, E, II> where
I: Compressed,
O: Decompressed,
E: Error,
II: Iterator<Item = Result<I, E>>,
F: Fn(I, &mut Vec<u8, Global>) -> Result<O, E>,
Implementors
sourceimpl<'a, I, T, E> FallibleStreamingIterator for Convert<'a, I, T> where
I: Iterator<Item = Result<&'a T, E>>,
impl<'a, I, T, E> FallibleStreamingIterator for Convert<'a, I, T> where
I: Iterator<Item = Result<&'a T, E>>,
sourceimpl<'a, R: Read> FallibleStreamingIterator for arrow2::io::avro::read::Decompressor<R>
Available on crate feature io_avro
only.
impl<'a, R: Read> FallibleStreamingIterator for arrow2::io::avro::read::Decompressor<R>
io_avro
only.type Error = ArrowError
type Item = Block
sourceimpl<'a, V, E> FallibleStreamingIterator for DynStreamingIterator<'a, V, E>
impl<'a, V, E> FallibleStreamingIterator for DynStreamingIterator<'a, V, E>
sourceimpl<A, I> FallibleStreamingIterator for arrow2::io::ndjson::write::Serializer<A, I> where
A: AsRef<dyn Array>,
I: Iterator<Item = Result<A, ArrowError>>,
impl<A, I> FallibleStreamingIterator for arrow2::io::ndjson::write::Serializer<A, I> where
A: AsRef<dyn Array>,
I: Iterator<Item = Result<A, ArrowError>>,
sourceimpl<A, I> FallibleStreamingIterator for arrow2::io::json::write::Serializer<A, I> where
A: AsRef<dyn Array>,
I: Iterator<Item = Result<A, ArrowError>>,
impl<A, I> FallibleStreamingIterator for arrow2::io::json::write::Serializer<A, I> where
A: AsRef<dyn Array>,
I: Iterator<Item = Result<A, ArrowError>>,
sourceimpl<I> FallibleStreamingIterator for BasicDecompressor<I> where
I: Iterator<Item = Result<CompressedDataPage, Error>>,
impl<I> FallibleStreamingIterator for BasicDecompressor<I> where
I: Iterator<Item = Result<CompressedDataPage, Error>>,
sourceimpl<I> FallibleStreamingIterator for Compressor<I> where
I: Iterator<Item = Result<EncodedPage, Error>>,
impl<I> FallibleStreamingIterator for Compressor<I> where
I: Iterator<Item = Result<EncodedPage, Error>>,
type Item = CompressedPage
type Error = Error
sourceimpl<I> FallibleStreamingIterator for Fuse<I> where
I: FallibleStreamingIterator,
impl<I> FallibleStreamingIterator for Fuse<I> where
I: FallibleStreamingIterator,
type Item = <I as FallibleStreamingIterator>::Item
type Error = <I as FallibleStreamingIterator>::Error
sourceimpl<I> FallibleStreamingIterator for Skip<I> where
I: FallibleStreamingIterator,
impl<I> FallibleStreamingIterator for Skip<I> where
I: FallibleStreamingIterator,
type Item = <I as FallibleStreamingIterator>::Item
type Error = <I as FallibleStreamingIterator>::Error
sourceimpl<I> FallibleStreamingIterator for Take<I> where
I: FallibleStreamingIterator,
impl<I> FallibleStreamingIterator for Take<I> where
I: FallibleStreamingIterator,
type Item = <I as FallibleStreamingIterator>::Item
type Error = <I as FallibleStreamingIterator>::Error
sourceimpl<I, F> FallibleStreamingIterator for Filter<I, F> where
I: FallibleStreamingIterator,
F: FnMut(&<I as FallibleStreamingIterator>::Item) -> bool,
impl<I, F> FallibleStreamingIterator for Filter<I, F> where
I: FallibleStreamingIterator,
F: FnMut(&<I as FallibleStreamingIterator>::Item) -> bool,
type Item = <I as FallibleStreamingIterator>::Item
type Error = <I as FallibleStreamingIterator>::Error
sourceimpl<I, F> FallibleStreamingIterator for SkipWhile<I, F> where
I: FallibleStreamingIterator,
F: FnMut(&<I as FallibleStreamingIterator>::Item) -> bool,
impl<I, F> FallibleStreamingIterator for SkipWhile<I, F> where
I: FallibleStreamingIterator,
F: FnMut(&<I as FallibleStreamingIterator>::Item) -> bool,
type Item = <I as FallibleStreamingIterator>::Item
type Error = <I as FallibleStreamingIterator>::Error
sourceimpl<I, F> FallibleStreamingIterator for TakeWhile<I, F> where
I: FallibleStreamingIterator,
F: FnMut(&<I as FallibleStreamingIterator>::Item) -> bool,
impl<I, F> FallibleStreamingIterator for TakeWhile<I, F> where
I: FallibleStreamingIterator,
F: FnMut(&<I as FallibleStreamingIterator>::Item) -> bool,
type Item = <I as FallibleStreamingIterator>::Item
type Error = <I as FallibleStreamingIterator>::Error
sourceimpl<I, F, B> FallibleStreamingIterator for Map<I, F, B> where
I: FallibleStreamingIterator,
F: FnMut(&<I as FallibleStreamingIterator>::Item) -> B,
impl<I, F, B> FallibleStreamingIterator for Map<I, F, B> where
I: FallibleStreamingIterator,
F: FnMut(&<I as FallibleStreamingIterator>::Item) -> B,
type Item = B
type Error = <I as FallibleStreamingIterator>::Error
sourceimpl<I, F, B> FallibleStreamingIterator for MapErr<I, F> where
I: FallibleStreamingIterator,
F: Fn(<I as FallibleStreamingIterator>::Error) -> B,
impl<I, F, B> FallibleStreamingIterator for MapErr<I, F> where
I: FallibleStreamingIterator,
F: Fn(<I as FallibleStreamingIterator>::Error) -> B,
type Item = <I as FallibleStreamingIterator>::Item
type Error = B
sourceimpl<I, F, B> FallibleStreamingIterator for MapRef<I, F> where
I: FallibleStreamingIterator,
F: Fn(&<I as FallibleStreamingIterator>::Item) -> &B,
B: ?Sized,
impl<I, F, B> FallibleStreamingIterator for MapRef<I, F> where
I: FallibleStreamingIterator,
F: Fn(&<I as FallibleStreamingIterator>::Item) -> &B,
B: ?Sized,
type Item = B
type Error = <I as FallibleStreamingIterator>::Error
sourceimpl<P> FallibleStreamingIterator for arrow2::io::parquet::read::Decompressor<P> where
P: PageIterator,
impl<P> FallibleStreamingIterator for arrow2::io::parquet::read::Decompressor<P> where
P: PageIterator,
sourceimpl<R: BufRead> FallibleStreamingIterator for FileReader<R>
impl<R: BufRead> FallibleStreamingIterator for FileReader<R>
sourceimpl<R: Read> FallibleStreamingIterator for BlockStreamIterator<R>
Available on crate feature io_avro
only.
impl<R: Read> FallibleStreamingIterator for BlockStreamIterator<R>
io_avro
only.