Add DebounceFunction and ThrottleFunction

Author: intitni

Pro

@@ -42,6 +42,7 @@ let package = Package(
             ]
         ),
         .library(name: "GitIgnoreCheck", targets: ["GitIgnoreCheck"]),
+        .library(name: "DebounceFunction", targets: ["DebounceFunction"]),
     ],
     dependencies: [
         // A fork of https://github.com/aespinilla/Tiktoken to allow loading from local files.
@@ -102,6 +103,8 @@ let package = Package(
             )]
         ),
 
+        .target(name: "DebounceFunction"),
+
         .target(
             name: "AppActivator",
             dependencies: [

Tool/Package.swift

@@ -1,8 +1,22 @@
-//
-//  File.swift
-//  
-//
-//  Created by Shangxin Guo on 2024/2/15.
-//
-
 import Foundation
+
+public actor DebounceFunction<T> {
+    let duration: TimeInterval
+    let block: (T) async -> Void
+
+    var task: Task<Void, Error>?
+
+    public init(duration: TimeInterval, block: @escaping (T) async -> Void) {
+        self.duration = duration
+        self.block = block
+    }
+
+    public func callAsFunction(_ t: T) async {
+        task?.cancel()
+        task = Task { [block, duration] in
+            try await Task.sleep(nanoseconds: UInt64(duration * 1_000_000_000))
+            await block(t)
+        }
+    }
+}
+

Tool/Sources/DebounceFunction/DebounceFunction.swift

@@ -1,8 +1,42 @@
-//
-//  File.swift
-//  
-//
-//  Created by Shangxin Guo on 2024/2/15.
-//
-
 import Foundation
+
+public actor ThrottleFunction<T> {
+    let duration: TimeInterval
+    let block: (T) async -> Void
+
+    var task: Task<Void, Error>?
+    var lastFinishTime: Date = .init(timeIntervalSince1970: 0)
+    var now: () -> Date = { Date() }
+
+    public init(duration: TimeInterval, block: @escaping (T) async -> Void) {
+        self.duration = duration
+        self.block = block
+    }
+
+    public func callAsFunction(_ t: T) async {
+        if task == nil {
+            scheduleTask(t, wait: now().timeIntervalSince(lastFinishTime) < duration)
+        }
+    }
+
+    func scheduleTask(_ t: T, wait: Bool) {
+        task = Task.detached { [weak self] in
+            guard let self else { return }
+            do {
+                if wait {
+                    try await Task.sleep(nanoseconds: UInt64(duration * 1_000_000_000))
+                }
+                await block(t)
+                await finishTask()
+            } catch {
+                await finishTask()
+            }
+        }
+    }
+
+    func finishTask() {
+        task = nil
+        lastFinishTime = now()
+    }
+}
+