Function test_start_mid_line

datafusion/datasource-json/src/boundary_stream.rs:442–457

()

    #[tokio::test]
    async fn test_start_mid_line() {
        // start=3, fetch_start=2. Bytes from offset 2: "ne1\nline2\nline3\n".
        // Should skip "ne1\n" and yield "line2\nline3\n".
        static DATA: &[u8] = b"line1\nline2\nline3\n";
        for &cs in CHUNK_SIZES {
            let (store, path) = make_chunked_store(DATA, cs).await;
            let s = AlignedBoundaryStream::new(store, path, 3, 100, 18, b'\n')
                .await
                .unwrap();
            assert_eq!(
                collect_stream(s).await,
                b"line2\nline3\n",
                "chunk_size={cs}"
            );
        }
    }

    #[tokio::test]
    async fn test_end_boundary_mid_line() {