/// Wait for all threads to finish and return leftovers
Wait for all threads to finish and return leftovers
Wait for all threads to finish and return leftovers
pub fn finish(&mut self) -> Vec<CompressTask> {
        let mut leftovers = Vec::new();
        while self.received != self.sent {
            leftovers.push(self.get_compr_block());
        }
        leftovers
    }
pub fn finish ( & mut self ) -> Vec < CompressTask > { let mut leftovers = Vec :: new ( ) ; while self . received != self . sent { leftovers . push ( self . get_compr_block ( ) ) ; } leftovers }
Wait for all threads to finish and return leftovers
Wait for all threads to finish and return leftovers
&mut self