Module stream 

Structs

AbortOnDrop 🔒

Aborts a task when its consumer is dropped before the end.

ConvertBatchStream 🔒

A stream that takes ScanBatches and produces (converts them to) [RecordBatch]es.

Enums

ScanBatch

All kinds of [Batch]es to produce in scanner.

Functions

spawn_compact_stream 🔒

Polls stream on its own compaction runtime task, buffering up to capacity batches ahead of the consumer. While polling, the task holds a permit of semaphore if one is given.

Type Aliases

ScanBatchStream