Struct ChainReader

Source

pub struct ChainReader<R, F>where
    R: Read,
    F: FnMut(Error) -> ErrorAction,
{ /* private fields */ }

Expand description

A sequential chaining reader that combines multiple Read instances with configurable error handling.

§Behavior

Readers are consumed in FIFO (first-in, first-out) order.
Automatically switches to the next reader when the current one reaches EOF (returns Ok(0)).
Allows custom error handling to decide whether to retry or skip on I/O errors.

§Comparison with `io::Chain`

Supports a dynamic queue of readers instead of a fixed pair.
Configurable error handling strategies: Retry or Skip
Automatically advances to the next reader on EOF.

顺序管道读取器，将多个 Read 实例组合为具有可配置错误处理的顺序读取管道。

§行为特性：

按先进先出顺序消费读取器。
当前读取器到达 EOF 时（返回 Ok(0)）自动切换至下一个。
允许自定义错误处理策略，决定在 I/O 错误时重试或跳过。

§与 `io::Chain` 的区别：

支持动态读取器队列而非固定两个。
可配置错误处理策略：重试或跳过。
EOF 时自动管理读取器切换。

Implementations§

Source §

impl<R, F> ChainReader<R, F>
where R: Read, F: FnMut(Error) -> ErrorAction,

Source

pub fn new(readers: VecDeque<R>, handle: F) -> Self

Creates a new ChainReader with the given reader queue and error handler.

The readers will be consumed in the order they appear in the readers queue. The handle callback determines behavior on I/O errors during reading.

§Parameters

readers: Queue of readers to process sequentially
handle: Error handling strategy callback

§Examples

use std::collections::VecDeque;
use std::io;
use chain_reader::{ChainReader, ErrorAction};

let mut readers = VecDeque::new();
readers.push_back("hello".as_bytes());
let error_handler = |e: io::Error| ErrorAction::Skip;
let chain = ChainReader::new(readers, error_handler);

使用指定的读取器队列和错误处理回调创建新的 ChainReader

读取器将按照队列中的顺序被消费。handle 回调用于决定读取时遇到 I/O 错误的处理策略

§参数

readers: 要顺序处理的读取器队列
handle: 错误处理策略回调

§示例

use std::collections::VecDeque;
use std::io;
use chain_reader::{ChainReader, ErrorAction};

let mut readers = VecDeque::new();
readers.push_back("hello".as_bytes());
let error_handler = |e: io::Error| ErrorAction::Skip;
let chain = ChainReader::new(readers, error_handler);

Source

pub fn push_back(&mut self, reader: R)

Appends a reader to the end of the processing queue

The reader will be processed after all existing readers in the queue have either reached EOF or been skipped due to errors.

§Parameters

reader: Reader to add to the end of the queue

§Examples

use std::collections::VecDeque;
use std::io;
use chain_reader::{ChainReader, ErrorAction};

let mut chain = ChainReader::new(VecDeque::new(), |e| ErrorAction::Skip);
chain.push_back(std::io::empty());

将读取器追加到处理队列末尾

该读取器将在队列中所有现有读取器处理完毕（到达 EOF 或因为错误被跳过）后进行处理

§参数

reader: 要添加到队列末尾的读取器

§示例

use std::collections::VecDeque;
use std::io;
use chain_reader::{ChainReader, ErrorAction};
let mut chain = ChainReader::new(VecDeque::new(), |e| ErrorAction::Skip);
chain.push_back(std::io::empty());