fix left over capture barrier

input-capture/src/lib.rs

@@ -132,31 +132,35 @@ pub struct InputCapture {
 impl InputCapture {
     /// create a new client with the given id
     pub async fn create(&mut self, id: CaptureHandle, pos: Position) -> Result<(), CaptureError> {
+        assert!(!self.id_map.contains_key(&id));
+
+        self.id_map.insert(id, pos);
+
         if let Some(v) = self.position_map.get_mut(&pos) {
             v.push(id);
             Ok(())
         } else {
             self.position_map.insert(pos, vec![id]);
-            self.id_map.insert(id, pos);
             self.capture.create(pos).await
         }
     }
 
     /// destroy the client with the given id, if it exists
     pub async fn destroy(&mut self, id: CaptureHandle) -> Result<(), CaptureError> {
-        if let Some(pos) = self.id_map.remove(&id) {
+        let pos = self
-            let destroy = if let Some(v) = self.position_map.get_mut(&pos) {
+            .id_map
-                v.retain(|&i| i != id);
+            .remove(&id)
-                // we were the last id registered at this position
+            .expect("no position for this handle");
-                v.is_empty()
+
-            } else {
+        log::debug!("destroying capture {id} @ {pos}");
-                // nothing to destroy
+        let remaining = self.position_map.get_mut(&pos).expect("id vector");
-                false
+        remaining.retain(|&i| i != id);
-            };
+
-            if destroy {
+        log::debug!("remaining ids @ {pos}: {remaining:?}");
-                self.position_map.remove(&pos);
+        if remaining.is_empty() {
-                self.capture.destroy(pos).await?;
+            log::debug!("destroying capture @ {pos} - no remaining ids");
-            }
+            self.position_map.remove(&pos);
+            self.capture.destroy(pos).await?;
         }
         Ok(())
     }