Function test_empty_range

datafusion/datasource-json/src/boundary_stream.rs:549–603

()

    #[tokio::test]
    async fn test_empty_range() {
        // start >= end — no complete line can exist, regardless of data.
        static DATA: &[u8] = b"line1\nline2\n";
        for &cs in CHUNK_SIZES {
            let (store, path) = make_chunked_store(DATA, cs).await;

            // start > end (non-zero start)
            let s = AlignedBoundaryStream::new(
                Arc::clone(&store),
                path.clone(),
                10,
                5,
                20,
                b'\n',
            )
            .await
            .unwrap();
            assert!(
                collect_stream(s).await.is_empty(),
                "start>end chunk_size={cs}"
            );

            // start == end == 0 (zero start, previously unguarded)
            let s = AlignedBoundaryStream::new(
                Arc::clone(&store),
                path.clone(),
                0,
                0,
                12,
                b'\n',
            )
            .await
            .unwrap();
            assert!(
                collect_stream(s).await.is_empty(),
                "start==end==0 chunk_size={cs}"
            );

            // start == end (non-zero)
            let s = AlignedBoundaryStream::new(
                Arc::clone(&store),
                path.clone(),
                6,
                6,
                12,
                b'\n',
            )
            .await
            .unwrap();
            assert!(
                collect_stream(s).await.is_empty(),
                "start==end==6 chunk_size={cs}"
            );
        }
    }

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