RxDart vs FxDart › #17 · Gasto agrupado por categoría

Gasto agrupado por categoría

Gana FxDart

• fx
• groupedBy
• map
• sumBy

Requisito

Totaliza nueve transacciones de agosto por categoría, e imprime los totales en el orden en que cada categoría aparece por primera vez en el extracto. Los datos están en el código; las dos versiones deben imprimir las líneas que aparecen bajo Salida esperada.

groceries: 69
transport: 23
dining: 72

Lado a lado

Por qué difieren

El agrupado es donde el compromiso del modelo push con «todo es un stream» sale caro. El groupBy de RxDart no puede devolver un mapa — la fuente podría no terminar nunca — así que devuelve un stream de streams: un GroupedStream por cada clave nueva. Para sacar los totales, cada stream interno debe plegarse (un Future), el future elevarse de vuelta a stream (asStream) y los resultados mezclarse con flatMap — tres capas de fontanería alrededor de un sum. (Un usuario rx pragmático puede esquivar groupBy por completo plegando el stream entero en un mapa mutable — más corto, pero abandona el operador del que trata este ejemplo y el agrupado vuelve a ser imperativo.) Y la forma tiene aristas afiladas: pliega con asyncExpand en lugar de flatMap y el programa entra en deadlock, porque pausar el stream exterior mientras se espera el total de un grupo detiene la fuente que debe completarse antes de que ningún grupo pueda cerrarse.

Los datos de FxDart son finitos por construcción, así que agrupar no necesita streams-de-streams: groupedBy produce records (key, items) corrientes en orden de primera aparición de la clave y la cadena sigue adelante, con sumBy haciendo la aritmética por grupo. Nada se aplaza porque nada sigue llegando. Para feeds vivos e ilimitados el diseño de GroupedStream es la decisión correcta — pero para un extracto que ya está en la mano, este es un trabajo con forma de pull y la versión pull lo dice en tres líneas. El veredicto se lo lleva FxDart.