fn drop()

in plasma-stream/src/server/receiver.rs [154:163]

• 6 lines of code
• 2 McCabe index (conditional complexity)

    fn drop(&mut self) {
        // ensure thread-safety by acquiring a lock to the set of objects being received;
        // `unwrap()` is OK here because no thread will panic wile holding the lock.s
        let mut receiving = self.receiving.lock().unwrap();

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