fn write_next_queued_chunk(&mut self) -> UnitResult {
        debug_assert!(self.currently_compressing_count > 0, "cannot wait for chunks as there are none left");

        assert_eq!( // propagate panics (in release mode unlikely, but possible of course)
                    self.pool.panic_count(), 0,
                    "OpenEXR compressor thread panicked \
            (maybe a debug assertion failed) - \
            Use non-parallel decompression to see panic messages."
        );

        let some_compressed_chunk = self.receiver.recv()
            .expect("cannot receive compressed block");

        self.currently_compressing_count -= 1;
        let (chunk_file_index, chunk_y_index, chunk) = some_compressed_chunk?;
        self.sorted_writer.write_or_stash_chunk(chunk_file_index, chunk_y_index, chunk)?;

        self.written_chunk_count += 1;
        Ok(())
    }
// private, as may underflow counter in release mode
private, as may underflow counter in release mode
private as may underflow counter in release mode
fn write_next_queued_chunk(&mut self) -> UnitResult {
        debug_assert!(self.currently_compressing_count > 0, "cannot wait for chunks as there are none left");
        assert_eq!( // propagate panics (in release mode unlikely, but possible of course)
                    self.pool.panic_count(), 0,
                    "OpenEXR compressor thread panicked \
            (maybe a debug assertion failed) - \
            Use non-parallel decompression to see panic messages."
        );
        let some_compressed_chunk = self.receiver.recv()
            .expect("cannot receive compressed block");
        self.currently_compressing_count -= 1;
        let (chunk_file_index, chunk_y_index, chunk) = some_compressed_chunk?;
        self.sorted_writer.write_or_stash_chunk(chunk_file_index, chunk_y_index, chunk)?;
        self.written_chunk_count += 1;
        Ok(())
    }
fn write_next_queued_chunk ( & mut self ) -> UnitResult { debug_assert ! ( self currently_compressing_count 0 " " ) ; assert_eq ! ( // propagate panics (in release mode unlikely, but possible of course) self pool panic_count ( ) 0 " \
 \
 " ) ; let some_compressed_chunk = self . receiver . recv ( ) . expect ( " " ) ; self . currently_compressing_count -= 1 ; let ( chunk_file_index , chunk_y_index , chunk ) = some_compressed_chunk ? ; self . sorted_writer . write_or_stash_chunk ( chunk_file_index , chunk_y_index , chunk ) ? ; self . written_chunk_count += 1 ; Ok ( ( ) ) }
private, as may underflow counter in release mode
private as may underflow counter in release mode
&mut self
&mut self