pub struct ParallelStreamingParser { /* private fields */ }Expand description
Parallel streaming parser for multi-core processing
Implementations§
Source§impl ParallelStreamingParser
impl ParallelStreamingParser
Sourcepub fn with_threads(threads: usize) -> Self
pub fn with_threads(threads: usize) -> Self
Create parser with specific number of worker threads
Sourcepub fn parse_parallel(
&self,
data: &[u8],
) -> Result<Vec<WorkingStreamingElement>, ParseError>
pub fn parse_parallel( &self, data: &[u8], ) -> Result<Vec<WorkingStreamingElement>, ParseError>
Parse data in parallel using multiple threads
Sourcepub fn get_stats(&self) -> WorkingStreamingStats
pub fn get_stats(&self) -> WorkingStreamingStats
Get current performance statistics
Trait Implementations§
Auto Trait Implementations§
impl Freeze for ParallelStreamingParser
impl RefUnwindSafe for ParallelStreamingParser
impl Send for ParallelStreamingParser
impl Sync for ParallelStreamingParser
impl Unpin for ParallelStreamingParser
impl UnwindSafe for ParallelStreamingParser
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