debounce

debounce 是 Combine 中的一个操作符，用于限制事件的频率。当 Publisher 发出事件时，debounce 会延迟一段指定的时间，只有在这段时间内没有收到新的事件时，才会将最后一个事件发出。这个操作符通常用于处理用户输入、滚动事件或任何高频率的事件流，防止过多的事件被迅速发送。

debounce 的签名

func debounce(for: Scheduler.TimeInterval, scheduler: Scheduler) -> Publishers.Debounce<Self>

• for: 指定的时间间隔，表示在发出事件之前要等待的时间。

• scheduler: 控制事件调度的 Scheduler，例如 DispatchQueue.main 或 RunLoop.main。

工作原理

debounce 只会在指定的时间间隔内没有新事件到达时，才会发出最近一次收到的事件。如果在这段时间内又有新事件到达，之前的事件会被丢弃，重新开始计时。

示例：基本用法

假设我们有一个 Publisher，它会发出一系列值，并使用 debounce 来限制输出的频率。

import Combine

let publisher = PassthroughSubject<Int, Never>()

let subscription = publisher
    .debounce(for: .seconds(1), scheduler: DispatchQueue.main) // 延迟 1 秒
    .sink { value in
        print("Received value: \(value)")
    }

// 模拟快速发送值
publisher.send(1)
publisher.send(2)
publisher.send(3)
DispatchQueue.main.asyncAfter(deadline: .now() + 0.5) {
    publisher.send(4) // 这会重置计时
}
DispatchQueue.main.asyncAfter(deadline: .now() + 1.5) {
    publisher.send(5) // 1 秒后发出值
}

输出结果（1 秒后）：

Received value: 5

在这个示例中，尽管我们发送了多个值，只有在最后一个事件（值 5）被发送后，经过 1 秒的延迟后才会被打印，因为 debounce 会丢弃之前的值。

示例：处理用户输入

debounce 通常用于处理高频率的事件，比如文本输入框中的输入事件：

import Combine

let textPublisher = PassthroughSubject<String, Never>()

let subscription = textPublisher
    .debounce(for: .seconds(0.5), scheduler: DispatchQueue.main) // 0.5 秒延迟
    .sink { value in
        print("User typed: \(value)")
    }

// 模拟用户输入
textPublisher.send("H")
textPublisher.send("He")
textPublisher.send("Hel")
textPublisher.send("Hell")
DispatchQueue.main.asyncAfter(deadline: .now() + 0.3) {
    textPublisher.send("Hello") // 0.5 秒内会重置计时
}
DispatchQueue.main.asyncAfter(deadline: .now() + 0.6) {
    textPublisher.send("Hello, World!") // 0.5 秒后发出
}

输出结果（0.5 秒后）：

User typed: Hello, World!

在这个示例中，用户在输入框中快速输入文本。debounce 等待 0.5 秒，如果在这段时间内没有新的输入，它就会发出最后一个输入的值。

debounce 与调度器

debounce 操作符需要一个调度器（scheduler）来指定延迟的行为。常见的调度器包括：

• DispatchQueue: 用于指定在主线程或后台线程上进行延迟。

• RunLoop: 用于基于运行循环的调度，适合与 UI 相关的操作。

使用 debounce 在后台线程

import Combine

let publisher = PassthroughSubject<String, Never>()

let subscription = publisher
    .debounce(for: .seconds(1), scheduler: DispatchQueue.main) // 在主线程延迟 1 秒
    .sink { value in
        print("Received value: \(value)")
    }

DispatchQueue.global().async {
    publisher.send("Hello")
    sleep(1) // 等待 1 秒
    publisher.send("World") // 这会在主线程上被发出
}

输出结果（1 秒后）：

Received value: World

在这个示例中，debounce 确保了只有在 1 秒内没有新值时，才会发出最后一个值。

debounce 的注意事项

• 时间间隔：debounce 设定的时间间隔应该根据具体需求调整，以避免丢失有用的事件。

• 丢弃事件：在时间间隔内收到的新事件会重置计时，这可能导致丢弃一些重要事件，使用时需谨慎。

• 与其他操作符组合：debounce 可以与其他操作符组合使用，增强流控制的灵活性。

总结

• debounce：用于限制流中事件的频率，防止过于频繁的事件触发。

• 适用场景：用户输入、滚动事件、点击事件等需要降低事件频率的场景。

• 调度器：可指定在哪个调度器上执行延迟，通常选择主线程以处理 UI 更新。

debounce 是一个强大的工具，用于控制事件流的输出频率，确保只有在特定的时间间隔内没有新的事件时才会处理最新的事件。通过适当地使用 debounce，你可以减少不必要的处理，提高应用程序的性能和响应速度。