pub struct Partial<I> { /* private fields */ }
Expand description
Mark the input as a partial buffer for streaming input.
Complete input means that we already have all of the data. This will be the common case with small files that can be read entirely to memory.
In contrast, streaming input assumes that we might not have all of the data. This can happen with some network protocol or large file parsers, where the input buffer can be full and need to be resized or refilled.
- [
ErrMode::Incomplete
] will report how much more data is needed. Parser::complete_err
transform [ErrMode::Incomplete
] to [ErrMode::Backtrack
]
See also StreamIsPartial
to tell whether the input supports complete or partial parsing.
See also [Special Topics: Parsing Partial Input][crate::_topic::partial].
§Example
Here is how it works in practice:
fn take_partial<'s>(i: &mut Partial<&'s [u8]>) -> PResult<&'s [u8], InputError<Partial<&'s [u8]>>> {
token::take(4u8).parse_next(i)
}
fn take_complete<'s>(i: &mut &'s [u8]) -> PResult<&'s [u8], InputError<&'s [u8]>> {
token::take(4u8).parse_next(i)
}
// both parsers will take 4 bytes as expected
assert_eq!(take_partial.parse_peek(Partial::new(&b"abcde"[..])), Ok((Partial::new(&b"e"[..]), &b"abcd"[..])));
assert_eq!(take_complete.parse_peek(&b"abcde"[..]), Ok((&b"e"[..], &b"abcd"[..])));
// if the input is smaller than 4 bytes, the partial parser
// will return `Incomplete` to indicate that we need more data
assert_eq!(take_partial.parse_peek(Partial::new(&b"abc"[..])), Err(ErrMode::Incomplete(Needed::new(1))));
// but the complete parser will return an error
assert_eq!(take_complete.parse_peek(&b"abc"[..]), Err(ErrMode::Backtrack(InputError::new(&b"abc"[..], ErrorKind::Slice))));
// the alpha0 function takes 0 or more alphabetic characters
fn alpha0_partial<'s>(i: &mut Partial<&'s str>) -> PResult<&'s str, InputError<Partial<&'s str>>> {
ascii::alpha0.parse_next(i)
}
fn alpha0_complete<'s>(i: &mut &'s str) -> PResult<&'s str, InputError<&'s str>> {
ascii::alpha0.parse_next(i)
}
// if there's a clear limit to the taken characters, both parsers work the same way
assert_eq!(alpha0_partial.parse_peek(Partial::new("abcd;")), Ok((Partial::new(";"), "abcd")));
assert_eq!(alpha0_complete.parse_peek("abcd;"), Ok((";", "abcd")));
// but when there's no limit, the partial version returns `Incomplete`, because it cannot
// know if more input data should be taken. The whole input could be "abcd;", or
// "abcde;"
assert_eq!(alpha0_partial.parse_peek(Partial::new("abcd")), Err(ErrMode::Incomplete(Needed::new(1))));
// while the complete version knows that all of the data is there
assert_eq!(alpha0_complete.parse_peek("abcd"), Ok(("", "abcd")));
Implementations§
Source§impl<I> Partial<I>where
I: StreamIsPartial,
impl<I> Partial<I>where
I: StreamIsPartial,
Sourcepub fn into_inner(self) -> I
pub fn into_inner(self) -> I
Extract the original Stream
Trait Implementations§
Source§impl<I, T> Compare<T> for Partial<I>where
I: Compare<T>,
impl<I, T> Compare<T> for Partial<I>where
I: Compare<T>,
Source§fn compare(&self, t: T) -> CompareResult
fn compare(&self, t: T) -> CompareResult
Source§impl<I> Offset<<Partial<I> as Stream>::Checkpoint> for Partial<I>where
I: Stream,
impl<I> Offset<<Partial<I> as Stream>::Checkpoint> for Partial<I>where
I: Stream,
Source§fn offset_from(&self, other: &<Partial<I> as Stream>::Checkpoint) -> usize
fn offset_from(&self, other: &<Partial<I> as Stream>::Checkpoint) -> usize
Source§impl<I> Offset for Partial<I>where
I: Stream,
impl<I> Offset for Partial<I>where
I: Stream,
Source§fn offset_from(&self, start: &Self) -> usize
fn offset_from(&self, start: &Self) -> usize
Source§impl<I: Ord> Ord for Partial<I>
impl<I: Ord> Ord for Partial<I>
1.21.0 · Source§fn max(self, other: Self) -> Selfwhere
Self: Sized,
fn max(self, other: Self) -> Selfwhere
Self: Sized,
Source§impl<I: PartialOrd> PartialOrd for Partial<I>
impl<I: PartialOrd> PartialOrd for Partial<I>
Source§impl<I: Stream> Stream for Partial<I>
impl<I: Stream> Stream for Partial<I>
Source§type IterOffsets = <I as Stream>::IterOffsets
type IterOffsets = <I as Stream>::IterOffsets
Source§type Checkpoint = Checkpoint<<I as Stream>::Checkpoint, Partial<I>>
type Checkpoint = Checkpoint<<I as Stream>::Checkpoint, Partial<I>>
Source§fn iter_offsets(&self) -> Self::IterOffsets
fn iter_offsets(&self) -> Self::IterOffsets
Source§fn eof_offset(&self) -> usize
fn eof_offset(&self) -> usize
Source§fn next_token(&mut self) -> Option<Self::Token>
fn next_token(&mut self) -> Option<Self::Token>
Source§fn offset_for<P>(&self, predicate: P) -> Option<usize>
fn offset_for<P>(&self, predicate: P) -> Option<usize>
Source§fn offset_at(&self, tokens: usize) -> Result<usize, Needed>
fn offset_at(&self, tokens: usize) -> Result<usize, Needed>
tokens
into the stream Read moreSource§fn next_slice(&mut self, offset: usize) -> Self::Slice
fn next_slice(&mut self, offset: usize) -> Self::Slice
Source§fn checkpoint(&self) -> Self::Checkpoint
fn checkpoint(&self) -> Self::Checkpoint
Source§fn reset(&mut self, checkpoint: &Self::Checkpoint)
fn reset(&mut self, checkpoint: &Self::Checkpoint)
Self::Checkpoint
Read moreSource§fn peek_token(&self) -> Option<(Self, Self::Token)>where
Self: Clone,
fn peek_token(&self) -> Option<(Self, Self::Token)>where
Self: Clone,
Source§fn peek_slice(&self, offset: usize) -> (Self, Self::Slice)where
Self: Clone,
fn peek_slice(&self, offset: usize) -> (Self, Self::Slice)where
Self: Clone,
Source§fn peek_finish(&self) -> (Self, Self::Slice)where
Self: Clone,
fn peek_finish(&self) -> (Self, Self::Slice)where
Self: Clone,
Source§impl<I> StreamIsPartial for Partial<I>where
I: StreamIsPartial,
impl<I> StreamIsPartial for Partial<I>where
I: StreamIsPartial,
Source§type PartialState = bool
type PartialState = bool
Source§fn complete(&mut self) -> Self::PartialState
fn complete(&mut self) -> Self::PartialState
Source§fn restore_partial(&mut self, state: Self::PartialState)
fn restore_partial(&mut self, state: Self::PartialState)
Source§fn is_partial_supported() -> bool
fn is_partial_supported() -> bool
Stream
is can ever be incompleteSource§fn is_partial(&self) -> bool
fn is_partial(&self) -> bool
Stream
is currently incompleteSource§impl<I> UpdateSlice for Partial<I>where
I: UpdateSlice,
impl<I> UpdateSlice for Partial<I>where
I: UpdateSlice,
Source§fn update_slice(self, inner: Self::Slice) -> Self
fn update_slice(self, inner: Self::Slice) -> Self
Output
type to be used as Stream
impl<I: Copy> Copy for Partial<I>
impl<I: Eq> Eq for Partial<I>
impl<I> StructuralPartialEq for Partial<I>
Auto Trait Implementations§
impl<I> Freeze for Partial<I>where
I: Freeze,
impl<I> RefUnwindSafe for Partial<I>where
I: RefUnwindSafe,
impl<I> Send for Partial<I>where
I: Send,
impl<I> Sync for Partial<I>where
I: Sync,
impl<I> Unpin for Partial<I>where
I: Unpin,
impl<I> UnwindSafe for Partial<I>where
I: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Layout§
Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.