Struct ParseOutput 

pub struct ParseOutput<I> { /* private fields */ }

Async output sink passed into a spider’s parse method.

Implementations

impl<I: 'static> ParseOutput<I>

pub async fn add_item(&self, item: I) -> Result<(), SpiderError>

Emits a scraped item into the runtime.

Use this when the current page produced one structured result that should continue through the configured pipeline chain. This call is async so the runtime can apply backpressure when downstream work is saturated.

pub async fn add_request(&self, request: Request) -> Result<(), SpiderError>

Emits a new request to be crawled.

Requests emitted here are forwarded into the scheduler path.

pub async fn add_items( &self, items: impl IntoIterator<Item = I>, ) -> Result<(), SpiderError>

Emits multiple scraped items into the runtime.

pub async fn add_requests( &self, requests: impl IntoIterator<Item = Request>, ) -> Result<(), SpiderError>

Emits multiple new requests to be crawled.

Trait Implementations

impl<I> Clone for ParseOutput<I>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<I: 'static> Debug for ParseOutput<I>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.