Async streams y flujos de valores

async/await es perfecto para “pide una cosa, espera una respuesta”. Pero muchas fuentes emiten valores continuamente: la ubicación del GPS, mensajes que llegan, el progreso de una descarga. Para eso están los async streams: una secuencia de valores en el tiempo que recorres con un bucle.

Un bucle sobre el tiempo

Un AsyncSequence es como un array cuyos elementos van llegando poco a poco. Lo recorres con for await, que espera cada valor:

for await ubicacion in gestorUbicacion.actualizaciones {
    print("Nueva posición: \(ubicacion)")
    // el bucle continúa cada vez que llega una ubicación nueva
}

El bucle no termina cuando “se acaban los datos ahora”: se pausa esperando el siguiente valor, y sigue cuando llega. Ideal para fuentes vivas.

Crear un flujo con AsyncStream

Envuelve cualquier fuente de eventos (un temporizador, un callback antiguo, un sensor) en un AsyncStream:

func contador() -> AsyncStream<Int> {
    AsyncStream { continuation in
        Task {
            for i in 1...5 {
                try? await Task.sleep(for: .seconds(1))
                continuation.yield(i)        // emite un valor
            }
            continuation.finish()            // termina el flujo
        }
    }
}

// consumirlo:
for await n in contador() {
    print(n)   // 1, 2, 3, 4, 5, uno por segundo
}

yield emite; finish cierra. Cualquier API basada en callbacks o notificaciones puede volverse un stream limpio y recorrible.

Cancelación

Los streams respetan la cancelación de tareas: si la Task que los consume se cancela (por ejemplo, la vista desaparece y su .task se cancela), el bucle for await termina de forma limpia. Por eso .task en SwiftUI y los streams se llevan tan bien:

.task {
    for await evento in fuente.eventos {
        procesar(evento)
    }
    // si la vista desaparece, el bucle se corta solo
}