В этом проекте используется AsyncStream для создания ассинхронного потока данных
private var continuation: AsyncStream<Void>.Continuation?
var triggerStream: AsyncStream<Void> {
AsyncStream { continuation in
self.continuation = continuation
}
} triggerStream позволяет в ручную управлять последовательностью, что бы добавить новые данные
continuation?.yield(())