macos: fix key-release with repeat logic

Author: feschber

input-emulation/src/macos.rs

@@ -11,8 +11,9 @@ use core_graphics::event_source::{CGEventSource, CGEventSourceStateID};
 use input_event::{Event, KeyboardEvent, PointerEvent};
 use keycode::{KeyMap, KeyMapping};
 use std::ops::{Index, IndexMut};
+use std::sync::Arc;
 use std::time::Duration;
-use tokio::task::AbortHandle;
+use tokio::{sync::Notify, task::AbortHandle};
 
 use super::error::MacOSEmulationCreationError;
 
@@ -23,6 +24,7 @@ pub(crate) struct MacOSEmulation {
     event_source: CGEventSource,
     repeat_task: Option<AbortHandle>,
     button_state: ButtonState,
+    notify_repeat_task: Arc<Notify>,
 }
 
 struct ButtonState {
@@ -79,20 +81,27 @@ impl MacOSEmulation {
     async fn spawn_repeat_task(&mut self, key: u16) {
         // there can only be one repeating key and it's
         // always the last to be pressed
-        self.kill_repeat_task();
+        self.cancel_repeat_task().await;
         let event_source = self.event_source.clone();
+        let notify = self.notify_repeat_task.clone();
         let repeat_task = tokio::task::spawn_local(async move {
-            tokio::time::sleep(DEFAULT_REPEAT_DELAY).await;
             loop {
+                tokio::select! {
+                    _ = tokio::time::sleep(DEFAULT_REPEAT_INTERVAL) => {},
+                    _ = notify.notified() => break,
+                }
                 key_event(event_source.clone(), key, 1);
-                tokio::time::sleep(DEFAULT_REPEAT_INTERVAL).await;
             }
+            // release key when cancelled
+            key_event(event_source.clone(), key, 0);
         });
         self.repeat_task = Some(repeat_task.abort_handle());
     }
-    fn kill_repeat_task(&mut self) {
+
+    async fn cancel_repeat_task(&mut self) {
         if let Some(task) = self.repeat_task.take() {
-            task.abort();
+            self.notify_repeat_task.notify_waiters();
+            task.await;
         }
     }
 }
@@ -346,7 +355,7 @@ impl Emulation for MacOSEmulation {
                     match state {
                         // pressed
                         1 => self.spawn_repeat_task(code).await,
-                        _ => self.kill_repeat_task(),
+                        _ => self.cancel_repeat_task().await,
                     }
                     key_event(self.event_source.clone(), code, state)
                 }