throttle는 입력 소스로부터 값이 발행될 때, 지정된 시간동안 한 번 만 값을 발행하도록 하는 Operator에요.

기능

• debounce와 마찬가지로 지연 시간을 지정할 수 있어요.
• debounce와 마찬가지로 스케쥴러를 지정할 수 있어요.
• latest 파라미터를 통해 발행할 이벤트를 선택할 수 있어요. latest가 true면 가장 마지막에 있는 값을, false면 가장 처음에 있는 값을 발행해요.

사용

• latest: true

let subject = PassthroughSubject<String, Never>()

subject
  .throttle(for: 1, scheduler: DispatchQueue.main, latest: true)
  .sink { value in
    print(value)
  }
  .store(in: &cancellables)

subject.send("H")
subject.send("He")
subject.send("Hel")
subject.send("Hell")
subject.send("Hello")

// 결과
(1초 기다린 뒤) Hello

• latest: false

let subject = PassthroughSubject<String, Never>()

subject
  .throttle(for: 1, scheduler: DispatchQueue.main, latest: false)
  .sink { value in
    print(value)
  }
  .store(in: &cancellables)

subject.send("H")
subject.send("He")
subject.send("Hel")
subject.send("Hell")
subject.send("Hello")

// 결과
(1초 기다린 뒤) H