AsyncStream не выполняет закрытие

Timer.scheduleTimer требует, чтобы он был запланирован в цикле выполнения. С практической точки зрения это означает, что мы хотели бы запланировать его в цикле выполнения основного потока. Итак, вы либо вызываете scheduleTimer из основного потока, либо создаете Timer и вручную добавляете(_:forMode:) его в RunLoop.main . См. раздел «Планирование таймеров в циклах выполнения» документации Timer.

Проще всего было бы просто возложить эту функцию на главного актера. Например.,

@MainActor
func countdown(to message: String) async throws { … }

Здесь также есть несколько других проблем:

1. Я бы предложил определить переменную countdown внутри AsyncStream:

   @MainActor
   func countdown(to message: String) async throws {
       guard !message.isEmpty else { return }
   
       let counter = AsyncStream<String> { continuation in
           var countdown = 3
           Timer.scheduledTimer(withTimeInterval: 1.0, repeats: true) { timer in
               continuation.yield("\(countdown)...")
               countdown -= 1
           }
       }
   
       for await countDownMessage in counter {
           try await say(countDownMessage)
       }
   }
   

2. AsyncStream никогда не заканчивается. Возможно, вы захотите закончить его, когда он достигнет нуля:

   @MainActor
   func countdown(to message: String) async throws {
       guard !message.isEmpty else { return }
   
       let counter = AsyncStream<String> { continuation in
           var countdown = 3
           Timer.scheduledTimer(withTimeInterval: 1.0, repeats: true) { timer in
               continuation.yield("\(countdown)...")
   
               // presumably you want this countdown timer to finish when it hits zero
   
               guard countdown > 0 else {
                   timer.invalidate()
                   continuation.finish()
                   return
               }
   
               // otherwise, decrement and carry on
   
               countdown -= 1
           }
       }
   
       for await countDownMessage in counter {
           try await say(countDownMessage)
       }
   }
   

3. Должно быть замыкание continuation.onTermination для обработки отмены асинхронной последовательности.

   @MainActor
   func countdown(to message: String) async throws {
       guard !message.isEmpty else { return }
   
       let counter = AsyncStream<String> { continuation in
           var countdown = 3
           let timer = Timer.scheduledTimer(withTimeInterval: 1.0, repeats: true) { timer in
               continuation.yield("\(countdown)...")
   
               // presumably you want this countdown timer to finish when it hits zero
   
               guard countdown > 0 else {
                   timer.invalidate()
                   continuation.finish()
                   return
               }
   
               // otherwise, decrement and carry on
   
               countdown -= 1
           }
   
           continuation.onTermination = { _ in
               timer.invalidate()
           }
       }
   
       for await countDownMessage in counter {
           try await say(countDownMessage)
       }
   }
   

Возвращаясь к первоначальному вопросу (почему это не работает), лично я бы вообще избегал использования Timer в сочетании с параллелизмом Swift. Таймер GCD был бы лучше, так как он не требует RunLoop. Даже лучше, я бы посоветовал Task.sleep. Излишне говорить, что это предназначено для работы с параллелизмом Swift, а также может быть отменено.

Я бы лично предложил что-то вроде:

func countdown(to message: String) async throws {
    guard !message.isEmpty else { return }
    
    let counter = AsyncStream<String> { continuation in
        let task = Task {
            for countdown in (0...3).reversed() {
                try await Task.sleep(for: .seconds(1))
                continuation.yield("\(countdown)...")
            }
            
            continuation.finish()
        }
        
        continuation.onTermination = { _ in
            task.cancel()
        }
    }
    
    for await countDownMessage in counter {
        try await say(countDownMessage)
    }
}