Timer.swift

class Timer: DataListner {
    
    let timer: DispatchSourceTimer
    
    init(closure: @escaping (UploadStatus<Int>) -> Void) {
        self.timer = DispatchSource.makeTimerSource(flags: [], queue: DispatchQueue.main)
        timer.schedule(deadline: .now(), repeating: 1)
        let progress = Progress()
        timer.setEventHandler(handler: {
            progress.completedUnitCount += 1
            progress.totalUnitCount = 10
            if progress.completedUnitCount == progress.totalUnitCount {
                closure(.completion(1))
            } else {
                closure(.progress(progress))
            }
        })
        timer.resume()
    }
    
    func remove() {
        print("timer remove")
        timer.cancel()
    }
}

        let publisher = UploadDataStreamPublisher<Int>(handler: {
            return Timer(closure: $0)
        })
        publisher
            .sink {
                print($0)
            }.store(in: &cancellable)