Function parser_handles_split_single_message

src/protocol/tests.rs:731–765

()

#[test]
fn parser_handles_split_single_message() -> Result<()> {
    let full = buffers::data_row(&[None, Some("bang"), Some("zug zug"), None, Some("!")]);

    let messages = parse_vec_chunks(vec![full.clone()])?;
    assert_eq!(messages.len(), 1);
    assert_data_row_fields(
        &messages[0],
        &[None, Some("bang"), Some("zug zug"), None, Some("!")],
    );

    let splits = [
        6,
        2,
        full.len().saturating_sub(2),
        full.len().saturating_sub(1),
        full.len().saturating_sub(5),
    ];

    for split in splits {
        if split == 0 || split >= full.len() {
            continue;
        }
        let first_len = full.len() - split;
        let first = full[..first_len].to_vec();
        let second = full[first_len..].to_vec();
        let messages = parse_vec_chunks(vec![first, second])?;
        assert_eq!(messages.len(), 1);
        assert_data_row_fields(
            &messages[0],
            &[None, Some("bang"), Some("zug zug"), None, Some("!")],
        );
    }

    Ok(())
}

#[test]
fn parser_handles_split_multiple_messages() -> Result<()> {