Struct Mapping 

pub struct Mapping { /* private fields */ }

表示一次 map 操作的调度状态。

• container：待映射的容器对象（通常为元组）
• mapper：映射器函数对象（lambda 或其他）
• collected：已收集的映射结果
• current_index：当前处理到的元素索引

Implementations

impl Mapping

pub fn new(container: &OnionStaticObject, mapper: &OnionStaticObject) -> Self

创建一个新的 Mapping 实例。

参数

• container - 待映射的容器对象（通常为元组）
• mapper - 映射器函数对象（lambda 或其他）

返回值

返回新创建的 Mapping 实例，初始状态下未处理任何元素。

Trait Implementations

impl Clone for Mapping

fn clone(&self) -> Mapping

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Runnable for Mapping

fn receive( &mut self, step_result: &StepResult, _gc: &mut GC<OnionObjectCell>, ) -> Result<(), RuntimeError>

接收子任务的执行结果，并收集到结果列表。

参数

• step_result - 子任务的执行结果，期望为 StepResult::Return
• _gc - 垃圾收集器引用（未使用）

返回值

• Ok(()) - 成功收集结果并推进索引
• Err(RuntimeError) - 收到非预期结果类型

fn step(&mut self, _gc: &mut GC<OnionObjectCell>) -> StepResult

执行 map 操作的一个调度步骤。

• 若当前元素存在，尝试用 mapper 处理之：
  • 若 mapper 是 lambda，则生成新 Runnable 进行调用
  • 若 mapper 为 false，跳过当前元素
  • 其他情况直接收集元素
• 若所有元素处理完毕，返回收集到的新元组

返回值

• StepResult::NewRunnable - 需要调度新任务
• StepResult::Continue - 继续下一个元素
• StepResult::Return - 所有元素处理完毕，返回结果
• StepResult::Error - 类型错误或其他异常

fn format_context(&self) -> String

格式化 map 调度器的当前上下文信息。

输出当前映射器、容器、进度和已收集结果数量，便于调试。

返回值

返回格式化的多行字符串，展示 map 操作的状态。