fn compress_all_blocks_parallel(mut self, meta: &MetaData, blocks: impl Iterator<Item=(usize, UncompressedBlock)>) -> UnitResult {
        let mut parallel_writer = match self.parallel_blocks_compressor(meta) {
            None => return self.compress_all_blocks_sequential(meta, blocks),
            Some(writer) => writer,
        };

        // TODO check block order if line order is not unspecified!
        for (index_in_header_increasing_y, block) in blocks {
            parallel_writer.add_block_to_compression_queue(index_in_header_increasing_y, block)?;
        }

        // TODO debug_assert_eq!(self.is_complete());
        Ok(())
    }
/// Compresses all blocks to the file.
/// The index of the block must be in increasing line order within the header.
/// Obtain iterator with `MetaData::collect_ordered_blocks(...)` or similar methods.
Compresses all blocks to the file.
The index of the block must be in increasing line order within the header.
Obtain iterator with `MetaData::collect_ordered_blocks(...)` or similar methods.
Compresses all blocks to the file . The index of the block must be in increasing line order within the header . Obtain iterator with ` MetaData :: collect_ordered_blocks ( ... ) ` or similar methods .
fn compress_all_blocks_parallel(mut self, meta: &MetaData, blocks: impl Iterator<Item=(usize, UncompressedBlock)>) -> UnitResult {
        let mut parallel_writer = match self.parallel_blocks_compressor(meta) {
            None => return self.compress_all_blocks_sequential(meta, blocks),
            Some(writer) => writer,
        };
        // TODO check block order if line order is not unspecified!
        for (index_in_header_increasing_y, block) in blocks {
            parallel_writer.add_block_to_compression_queue(index_in_header_increasing_y, block)?;
        }
        // TODO debug_assert_eq!(self.is_complete());
        Ok(())
    }
fn compress_all_blocks_parallel ( mut self , meta : & MetaData , blocks : impl Iterator < Item = ( usize , UncompressedBlock ) > ) -> UnitResult { let mut parallel_writer = match self . parallel_blocks_compressor ( meta ) { None => return self . compress_all_blocks_sequential ( meta , blocks ) , Some ( writer ) => writer , } ; // TODO check block order if line order is not unspecified! for ( index_in_header_increasing_y , block ) in blocks { parallel_writer . add_block_to_compression_queue ( index_in_header_increasing_y , block ) ? ; } // TODO debug_assert_eq!(self.is_complete()); Ok ( ( ) ) }
Compresses all blocks to the file.
Compresses all blocks to the file .
mut self
meta
&MetaData
blocks
impl Iterator<Item=(usize, UncompressedBlock)>
mut self
meta
&MetaData
blocks
impl Iterator<Item=(usize, UncompressedBlock)>