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 stream 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, use await for, el cual procesa cada valor a medida que llega.

También puedes escuchar un stream utilizando el método listen(), el cual recibe una función de callback:

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

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

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

Desafío

Fácil

¡Vamos a construir un sistema de temporizador de cuenta regresiva que emita valores a lo largo del tiempo utilizando 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 para 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>. Este debe emitir cadenas en el formato 'T-minus [number]' para cada número desde start hasta 1, y luego 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 async y:
- Crear una instancia de Countdown comenzando desde 3
- Imprimir 'Number countdown:'
- Usar await for para iterar a través de countDown() e imprimir cada número
- Imprimir una línea vacía
- Imprimir 'Launch sequence:'
- Usar await for para iterar a través de countDownWithMessage() e imprimir cada mensaje

Observa cómo cada sentencia 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!

Hoja de referencia

Un Stream entrega una secuencia de valores a lo largo del tiempo, a diferencia de un Future que entrega un solo valor. Los streams son ideales para eventos, actualizaciones en tiempo real o para procesar datos pieza por pieza.

Crea un stream usando una función generadora asíncrona con async* y yield:

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

Consume un stream usando await for:

Future<void> main() async {
  await for (var number in countToThree()) {
    print(number);
  }
}

Alternativamente, usa el método listen() con un callback:

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

También puedes crear un stream desde un iterable usando Stream.fromIterable().

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
}