Struct PassThroughProcessor 

pub struct PassThroughProcessor<T> { /* private fields */ }

A pass-through processor that returns items unchanged.

This processor implements the identity function for batch processing pipelines. It takes an input item and returns it unchanged, making it useful for scenarios where you need a processor in the pipeline but don’t want to transform the data.

Type Parameters

• T: The item type that will be passed through unchanged. Must implement Clone.

Use Cases

• Testing batch processing pipelines without data transformation
• Placeholder processor during development
• Pipelines where processing logic is conditional and sometimes bypassed
• Maintaining consistent pipeline structure when transformation is optional

Performance

This processor performs a clone operation on each item. For large or complex data structures, consider whether pass-through processing is necessary or if the pipeline can be restructured to avoid unnecessary cloning.

Examples

use spring_batch_rs::core::item::{ItemProcessor, PassThroughProcessor};

let processor = PassThroughProcessor::<String>::new();
let input = "Hello, World!".to_string();
let result = processor.process(&input).unwrap();
assert_eq!(result, input);

Using with different data types:

use spring_batch_rs::core::item::{ItemProcessor, PassThroughProcessor};

// With integers
let int_processor = PassThroughProcessor::<i32>::new();
let number = 42;
let result = int_processor.process(&number).unwrap();
assert_eq!(result, number);

// With custom structs
#[derive(Clone, PartialEq, Debug)]
struct Person {
    name: String,
    age: u32,
}

let person_processor = PassThroughProcessor::<Person>::new();
let person = Person {
    name: "Alice".to_string(),
    age: 30,
};
let result = person_processor.process(&person).unwrap();
assert_eq!(result, person);

Implementations

impl<T: Clone> PassThroughProcessor<T>

pub fn new() -> Self

Creates a new PassThroughProcessor.

Returns

A new instance of PassThroughProcessor that will pass through items of type T.

Examples

use spring_batch_rs::core::item::PassThroughProcessor;

let processor = PassThroughProcessor::<String>::new();

Trait Implementations

impl<T: Default> Default for PassThroughProcessor<T>

fn default() -> PassThroughProcessor<T>

Returns the “default value” for a type.

impl<T: Clone> ItemProcessor<T, T> for PassThroughProcessor<T>

fn process(&self, item: &T) -> ItemProcessorResult<T>

Processes an item by returning it unchanged.

Parameters

• item: The item to process (will be cloned and returned unchanged)

Returns

• Ok(cloned_item) - Always succeeds and returns a clone of the input item

Examples

use spring_batch_rs::core::item::{ItemProcessor, PassThroughProcessor};

let processor = PassThroughProcessor::<Vec<i32>>::new();
let input = vec![1, 2, 3];
let result = processor.process(&input).unwrap();
assert_eq!(result, input);