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
Compares self to another value for equality
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,
Compares and returns the maximum of two values. Read more
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
Iterate with the offset from the current location
Source§type Checkpoint = Checkpoint<<I as Stream>::Checkpoint, Partial<I>>
type Checkpoint = Checkpoint<<I as Stream>::Checkpoint, Partial<I>>
A parse location within the stream
Source§fn iter_offsets(&self) -> Self::IterOffsets
fn iter_offsets(&self) -> Self::IterOffsets
Iterate with the offset from the current location
Source§fn eof_offset(&self) -> usize
fn eof_offset(&self) -> usize
Returns the offset to the end of the input
Source§fn next_token(&mut self) -> Option<Self::Token>
fn next_token(&mut self) -> Option<Self::Token>
Split off the next token from the input
Source§fn offset_for<P>(&self, predicate: P) -> Option<usize>
fn offset_for<P>(&self, predicate: P) -> Option<usize>
Finds the offset of the next matching token
Source§fn offset_at(&self, tokens: usize) -> Result<usize, Needed>
fn offset_at(&self, tokens: usize) -> Result<usize, Needed>
Get the offset for the number of
tokens
into the stream Read moreSource§fn next_slice(&mut self, offset: usize) -> Self::Slice
fn next_slice(&mut self, offset: usize) -> Self::Slice
Split off a slice of tokens from the input Read more
Source§fn checkpoint(&self) -> Self::Checkpoint
fn checkpoint(&self) -> Self::Checkpoint
Save the current parse location within the stream
Source§fn reset(&mut self, checkpoint: &Self::Checkpoint)
fn reset(&mut self, checkpoint: &Self::Checkpoint)
Revert the stream to a prior
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,
Split off the next token from the input
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,
Split off a slice of tokens from the input
Source§fn peek_finish(&self) -> (Self, Self::Slice)where
Self: Clone,
fn peek_finish(&self) -> (Self, Self::Slice)where
Self: Clone,
Advance to the end of the stream
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
Whether the stream is currently partial or complete
Source§fn complete(&mut self) -> Self::PartialState
fn complete(&mut self) -> Self::PartialState
Mark the stream is complete
Source§fn restore_partial(&mut self, state: Self::PartialState)
fn restore_partial(&mut self, state: Self::PartialState)
Restore the stream back to its previous state
Source§fn is_partial_supported() -> bool
fn is_partial_supported() -> bool
Report whether the
Stream
is can ever be incompleteSource§fn is_partial(&self) -> bool
fn is_partial(&self) -> bool
Report whether the
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
Convert an
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
Mutably borrows from an owned value. Read more