Combine variable throttling time

combineVariableThrottle.swift

// Originally found here: https://www.reddit.com/r/swift/comments/dvi5jj/dynamic_throttling_in_combine/?rdt=37713

import Combine
import Foundation

class Example {
    @Published var throttleInterval: DispatchQueue.SchedulerTimeType.Stride = 1
    @Published var valuesPublisher: Int = 0
    var cancellable: AnyCancellable?
    var timerSendValues: Timer?
    var timerChangeThrottle: Timer?
    
    init() {
        
        timerSendValues = Timer.scheduledTimer(withTimeInterval: 0.5, repeats: true) { [weak self] timer in
            guard let self else { return }
            self.valuesPublisher += 1
        }
        
        timerChangeThrottle = Timer.scheduledTimer(withTimeInterval: 10, repeats: true) { [weak self] timer in
            guard let self else { return }
            self.throttleInterval = self.throttleInterval == 1 ? 5 : 1
        }
        
        cancellable = $throttleInterval
            .removeDuplicates()
            .map { [unowned self] seconds -> AnyPublisher<Int, Never> in
                $valuesPublisher
                    .throttle(
                        for: seconds,
                        scheduler: DispatchQueue.main,
                        latest: true
                    )
                    .eraseToAnyPublisher()
            }
            .switchToLatest()
            .sink { [unowned self] value in
                print("Value: \(value) throttle interval: \(self.throttleInterval)")
                
            }
    }
}

let example = Example()