Fundamentos de Streams

Parte de la sección Programación Orientada a Objetos del Journey de Dart de Coddy. Lección 77 de 110.

Mientras que un Future entrega un único valor, un Stream entrega una secuencia de valores a lo largo del tiempo. Piénsalo como una tubería que puede emitir múltiples fragmentos de datos: perfecto para eventos, actualizaciones en tiempo real o para procesar datos pieza por pieza.

Puedes crear un flujo simple usando Stream.fromIterable() o una función generadora asíncrona con async* y yield:

Stream<int> countToThree() async* {
  yield 1;
  yield 2;
  yield 3;
}

Future<void> main() async {
  await for (var number in countToThree()) {
    print(number);
  }
}
// Salida: 1, 2, 3

La palabra clave async* marca una función que devuelve un Stream, y yield emite cada valor. Para consumir el stream, usa await for, que procesa cada valor a medida que llega.

También puedes escuchar un flujo usando el método listen(), que recibe una función de devolución de llamada:

Stream<String> greetings() async* {
  yield 'Hello';
  yield 'Hi';
  yield 'Hey';
}

void main() {
  greetings().listen((message) {
    print(message);
  });
}

La diferencia clave con los Futures: un Future se completa una vez con un único valor, mientras que un Stream puede emitir muchos valores antes de terminar. Esto hace que los Streams sean ideales para gestionar datos continuos, como las interacciones del usuario, las lecturas de sensores o los datos que llegan en fragmentos.

Desafío

Fácil

¡Construyamos un sistema de temporizador de cuenta regresiva que emita valores a lo largo del tiempo mediante streams! Crearás una clase que genere una secuencia de números de cuenta regresiva, demostrando cómo los streams entregan múltiples valores en lugar de solo uno.

Organizarás tu código en dos archivos:

countdown.dart: Crea una clase Countdown que genere streams de cuenta regresiva. Tu clase debe tener:
- Un campo start (int) que almacene el número inicial de la cuenta regresiva
- Un constructor que reciba el número inicial
- Un método countDown() que devuelva un Stream<int>. Usa async* y yield para emitir números desde start hasta 0 (inclusive)
- Un método countDownWithMessage() que devuelva un Stream<String>. Debe emitir cadenas con el formato 'T-minus [number]' para cada número desde start hasta 1, y después emitir 'Liftoff!' como valor final
main.dart: Importa tu archivo de cuenta regresiva y demuestra ambos métodos de stream. Tu función main debe ser asíncrona y:
- Crear una instancia de Countdown que comience en 3
- Imprimir Number countdown:
- Usar await for para iterar por countDown() e imprimir cada número
- Imprimir una línea vacía
- Imprimir Launch sequence:
- Usar await for para iterar por countDownWithMessage() e imprimir cada mensaje

Observa cómo cada instrucción yield emite un valor a través del stream, y await for procesa cada valor a medida que llega. A diferencia de un Future, que entrega un solo resultado, ¡tus streams emitirán múltiples valores en secuencia!

Salida esperada:

Number countdown:
3
2
1
0

Launch sequence:
T-minus 3
T-minus 2
T-minus 1
Liftoff!

Pruébalo tú mismo

import 'countdown.dart';

Future<void> main() async {
  // TODO: Crea una instancia de Countdown comenzando desde 3
  
  // TODO: Imprime 'Number countdown:'
  
  // TODO: Usa await for para iterar a través de countDown() e imprimir cada número
  
  // TODO: Imprime una línea vacía
  
  // TODO: Imprime 'Launch sequence:'
  
  // TODO: Usa await for para iterar a través de countDownWithMessage() e imprimir cada mensaje
}