Struct RasterStreamReader 

pub struct RasterStreamReader { /* private fields */ }

Async raster stream reader.

Reads real GeoTIFF files, extracting metadata from IFD tags and reading actual tile/strip data for each chunk.

Implementations

impl RasterStreamReader

pub async fn new<P: AsRef<Path>>( path: P, config: RasterStreamConfig, ) -> Result<Self>

Create a new raster stream reader.

Opens the GeoTIFF file and reads its metadata (dimensions, data type, geotransform, CRS, nodata value) from the TIFF IFD.

pub fn with_bands(self, bands: Vec<usize>) -> Self

Set which bands to read.

pub async fn start(&mut self) -> Result<()>

Start the streaming process.

pub async fn read_chunk(&self, row: usize, col: usize) -> Result<RasterChunk>

Read a specific chunk from the raster.

This actually reads tile/strip data from the GeoTIFF file for the given chunk coordinates.

pub async fn read_chunks( &self, chunks: Vec<(usize, usize)>, ) -> Result<Vec<RasterChunk>>

Read multiple chunks in parallel.

pub fn metadata(&self) -> &RasterMetadata

Get the metadata for this raster.

pub fn config(&self) -> &RasterStreamConfig

Get the stream configuration.

pub fn format(&self) -> RasterFormat

Get the detected file format.

Trait Implementations

impl RasterStreaming for RasterStreamReader

fn next_chunk<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<RasterChunk>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the next chunk from the stream.

fn next_chunks<'life0, 'async_trait>( &'life0 mut self, count: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<RasterChunk>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get multiple chunks in parallel.

fn seek_to_chunk<'life0, 'async_trait>( &'life0 mut self, row: usize, col: usize, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Skip to a specific chunk by index.

fn total_chunks(&self) -> (usize, usize)

Get the total number of chunks.

fn current_position(&self) -> (usize, usize)

Get the current position in the stream.

fn has_more_chunks(&self) -> bool

Check if the stream has more chunks.