79 lines
1.8 KiB
Swift
79 lines
1.8 KiB
Swift
//
|
|
// Copyright 2025 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
//
|
|
|
|
@testable import SignalServiceKit
|
|
import Testing
|
|
|
|
struct DebouncedTaskTest {
|
|
@Test
|
|
func testDebounce() async {
|
|
actor TestActor {
|
|
var allowRunning = false
|
|
var count = 0
|
|
|
|
func setAllowRunning() {
|
|
self.allowRunning = true
|
|
}
|
|
|
|
func increment() -> Int {
|
|
count += 1
|
|
return count
|
|
}
|
|
}
|
|
|
|
let testActor = TestActor()
|
|
|
|
let debouncedTask = DebouncedTask { () async -> Int in
|
|
while await !testActor.allowRunning {
|
|
await Task.yield()
|
|
}
|
|
|
|
return await testActor.increment()
|
|
}
|
|
|
|
let taskOne = debouncedTask.run()
|
|
let taskTwo = debouncedTask.run()
|
|
let taskThree = debouncedTask.run()
|
|
|
|
await testActor.setAllowRunning()
|
|
|
|
let countOne = await taskOne.value
|
|
let countTwo = await taskTwo.value
|
|
let countThree = await taskThree.value
|
|
|
|
#expect(countOne == 1)
|
|
#expect(countTwo == 1)
|
|
#expect(countThree == 1)
|
|
#expect(await debouncedTask.run().value == 2)
|
|
}
|
|
|
|
@Test
|
|
func testIsCurrentlyRunning() async {
|
|
actor TestActor {
|
|
var allowRunning = false
|
|
|
|
func setAllowRunning() {
|
|
allowRunning = true
|
|
}
|
|
}
|
|
|
|
let testActor = TestActor()
|
|
|
|
let debouncedTask = DebouncedTask {
|
|
while await !testActor.allowRunning {
|
|
await Task.yield()
|
|
}
|
|
}
|
|
|
|
let taskOne = debouncedTask.run()
|
|
#expect(debouncedTask.isCurrentlyRunning() != nil)
|
|
|
|
await testActor.setAllowRunning()
|
|
|
|
await taskOne.value
|
|
#expect(debouncedTask.isCurrentlyRunning() == nil)
|
|
}
|
|
}
|