Angular 41: Fundamentos de Observables de RxJS
easy⏱ 5 mincourseangular
Streams basados en push vs. Promises
Una Promise es de una sola vez: la esperas con await y obtienes exactamente un valor (o un error), para siempre. Un Observable te empuja valores cuando quiere — de forma síncrona, tras un retraso, repetidamente, o nunca. Por eso RxJS es ideal para cosas como streams de entrada del usuario, mensajes de WebSocket o sondeo periódico, no solo llamadas HTTP puntuales.
const numbers$ = of(1, 2, 3, 4, 5, 6);
numbers$
.pipe(
filter((n) => n % 2 === 0),
map((n) => n * 2),
)
.subscribe((value) => console.log(value));
// logs: 4, 8, 12
pipe() es solo una tubería de transformación
Cada operador dentro de .pipe(...) toma el stream anterior y devuelve uno nuevo — nada se ejecuta hasta la llamada final a .subscribe(), igual que el comportamiento de observable frío que viste con HttpClient.