Struct ConsoleWriterPipeline 

pub struct ConsoleWriterPipeline;

A pipeline that prints scraped items to the console.

Implementations

impl ConsoleWriterPipeline

pub fn new() -> Self

Creates a new ConsoleWriterPipeline.

Trait Implementations

impl Default for ConsoleWriterPipeline

fn default() -> Self

Returns the “default value” for a type.

impl<I: ScrapedItem> Pipeline<I> for ConsoleWriterPipeline

fn name(&self) -> &str

Returns the name of the pipeline.

fn process_item<'life0, 'async_trait>( &'life0 self, item: I, ) -> Pin<Box<dyn Future<Output = Result<Option<I>, PipelineError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Processes a single scraped item.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), PipelineError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called when the spider is closing.

fn get_state<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, PipelineError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the current state of the pipeline as a JSON value.

fn restore_state<'life0, 'async_trait>( &'life0 self, _state: Value, ) -> Pin<Box<dyn Future<Output = Result<(), PipelineError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Restores the pipeline’s state from a JSON value.