Function read_vec_dynamic_items

rust/fory-core/src/serializer/codec.rs:2063–2120

(
    context: &mut ReadContext,
    len: u32,
    header: u8,
    remote_field_type: &FieldType,
)

}

fn read_vec_dynamic_items<T, C>(
    context: &mut ReadContext,
    len: u32,
    header: u8,
    remote_field_type: &FieldType,
) -> Result<Vec<T>, Error>
where
    T: 'static,
    C: Codec<T>,
{
    let is_track_ref = (header & TRACKING_REF) != 0;
    let has_null = (header & HAS_NULL) != 0;
    let is_same_type = (header & IS_SAME_TYPE) != 0;
    let is_declared = (header & DECL_ELEMENT_TYPE) != 0;
    let elem_ref_mode = if is_track_ref {
        RefMode::Tracking
    } else if has_null {
        RefMode::NullOnly
    } else {
        RefMode::None
    };
    let mut vec = Vec::with_capacity(check_sequence_len(context, len)?);
    if is_same_type {
        if C::is_polymorphic() {
            if is_declared {
                return Err(Error::invalid_data(
                    "polymorphic collection element metadata must be written in the payload",
                ));
            }
            let type_info = context.read_any_type_info()?;
            for _ in 0..len {
                vec.push(C::read_with_type_info(
                    context,
                    elem_ref_mode,
                    type_info.clone(),
                )?);
            }
        } else {
            let element_type = if is_declared {
                generic_field_type(remote_field_type, 0, "list")?.clone()
            } else {
                C::read_type_info_as_field_type(context)?
            };
            for _ in 0..len {
                if C::is_shared_ref() {
                    vec.push(C::read_with_mode(context, elem_ref_mode, false)?);
                } else {
                    vec.push(C::read_data_with_type(context, &element_type)?);
                }
            }
        }
    } else {
        for _ in 0..len {
            vec.push(C::read_with_mode(context, elem_ref_mode, true)?);
        }
    }
    Ok(vec)
}