Skip to main content

next_chunk

risingwave_object_store::benchmark::read

Function next_chunk 

Source 
async fn next_chunk(
    stream: &mut ObjectDataStream,
    sample: &mut Sample,
    first_poll: bool,
    trace: &mut RequestTrace<'_>,
    token: &CancellationToken,
) -> Result<Option<usize>>