fn drop()

in plasma-stream/src/server/sender.rs [224:235]

• 11 lines of code
• 4 McCabe index (conditional complexity)

    fn drop(&mut self) {
        if self.delete_after_send {
            // ensure thread-safety by acquiring a lock to the set of objects scheduled for deletion;
            // `unwrap()` is OK here because no thread will panic wile holding the lock.
            let mut deleting = self.deleting.lock().unwrap();

            // remove all specified objects from the set
            for oid in self.object_ids.iter() {
                deleting.remove(oid);
            }
        }
    }