Struct PrefetchRecordSource 

pub struct PrefetchRecordSource { /* private fields */ }

Single-worker deterministic prefetch with count and memory backpressure.

Implementations

impl PrefetchRecordSource

pub fn try_new<S>(source: S) -> RecordsResult<Self>

where S: BoundedSpatialRecordSource + Send + 'static,

Starts prefetch using source.options().prefetch_chunks() as queue capacity.

Trait Implementations

impl BoundedSpatialRecordSource for PrefetchRecordSource

fn schema(&self) -> &SchemaDescriptor

Schema shared by every emitted record.

fn options(&self) -> &StreamOptions

Validated execution options.

fn memory_tracker(&self) -> &MemoryTracker

Exact tracker shared by emitted chunk leases.

fn cancellation_token(&self) -> CancellationToken

Cooperative cancellation state checked at chunk boundaries.

fn max_chunk_bytes(&self) -> u64

Conservative maximum resident bytes for one emitted chunk.

fn next_chunk(&mut self) -> Option<RecordsResult<SpatialRecordChunk>>

Returns the next leased chunk, or None after an explicit end.

impl Drop for PrefetchRecordSource

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.