Skip to main content

assert_batch_size_zero_single_page

Function assert_batch_size_zero_single_page 

Source
pub async fn assert_batch_size_zero_single_page<S: Source + ?Sized>(source: &S)
Expand description

Check 9. Drive a source built with batch_size = 0 and assert it yields the entire result set as a single StreamPage — the documented “no batching” sentinel (small lookup tables, sinks that prefer one large request).

Asserts the source produced at least one record and that exactly one page carried records (a trailing empty terminal page carrying only a bookmark is tolerated). Panics if the data is split across multiple non-empty pages.