RxDart vs FxDart › #18 · Dos feeds, estrictamente en orden

Dos feeds, estrictamente en orden

Empate

• fx
• concat
• map

Requisito

Una revisión de incidente necesita la cola del log de ayer seguida del log de hoy como una sola lista numerada — la primera entrada de hoy no debe aparecer nunca antes de la última de ayer. Los datos están en el código; las dos versiones deben imprimir las líneas que aparecen bajo Salida esperada.

1. 23:41  cache flushed
2. 23:52  nightly backup started
3. 23:58  nightly backup finished
4. 00:04  cache warmed
5. 00:12  first request served
6. 06:30  daily report generated
7. 07:02  queue drained

Lado a lado

Por qué difieren

Ambas bibliotecas escriben «este feed, y luego aquel» como un solo operador, pero cada modelo garantiza el orden con su propio mecanismo. El concatWith de RxDart es un secuenciador de suscripciones: no se suscribe al stream de hoy hasta que el de ayer dispara done, así que el orden se mantiene incluso si ambas fuentes están vivas y la de hoy hubiera estado lista para emitir antes. El concat de FxDart es un secuenciador de demanda: la cadena tira del segundo iterable solo después de agotar el primero, y con dos listas en memoria eso es todo el orden que hay que organizar.

Ese hueco de mecanismo importa exactamente cuando las fuentes son genuinamente push — un stream que empieza a emitir en cuanto alguien se suscribe necesita la suscripción diferida de concatWith, donde un pipeline pull tendría primero que almacenar el feed aún no deseado. Sobre datos fijos los dos colapsan en las mismas siete líneas y el mismo map. Empate: el operador es vocabulario compartido, y cada modelo lo implementa con la herramienta que ya tenía.