Transformar streams

Akka Streams proporciona un amplio conjunto de operadores para Source y Flow que reflejan la API de colecciones de Scala, pero se ejecutan de forma asíncrona y respetan la contrapresión.

Cada operador devuelve un esquema nuevo, por lo que las transformaciones se componen de forma declarativa antes de que se ejecute el flujo.

map aplica una función síncrona a cada elemento; filter descarta los elementos que no cumplen un predicado. Son los operadores fundamentales de la transformación elemento a elemento.

Ambos conservan el orden y propagan la finalización y los fallos hacia abajo.

Cuando una entrada debe producir varias salidas, use mapConcat. Recibe una función que devuelve un iterable y aplana los resultados en el flujo.

Devolver una colección vacía descarta el elemento de forma efectiva.

grouped(n) agrupa elementos consecutivos en un Seq de hasta n elementos, lo que resulta útil para escrituras masivas en bases de datos. sliding(n) emite ventanas superpuestas.

La agrupación reduce la sobrecarga por elemento en canalizaciones con un uso intensivo de E/S.

scan emite el acumulador actualizado después de cada elemento, lo que proporciona un flujo de estado evolutivo. fold emite únicamente el valor acumulado final cuando se completa el flujo ascendente.

Use scan para contadores en tiempo real y fold para agregaciones terminales.

mapAsync(parallelism) llama a una función que devuelve un Future y emite los resultados en orden, ejecutando de forma concurrente hasta parallelism futures.

Úselo para llamadas asíncronas, como consultas a bases de datos o solicitudes HTTP, cuando el orden sea importante.

mapAsyncUnordered se comporta como mapAsync, pero emite cada resultado en cuanto se completa, ignorando el orden de entrada.

Puede mejorar el rendimiento cuando al flujo descendente no le importa el orden, ya que un future lento deja de bloquear a los más rápidos.

Para transformaciones por elemento que necesitan un estado local mutable, statefulMapConcat crea un estado nuevo en cada materialización y devuelve un iterable de resultados.

Es la forma segura de mantener contadores o búferes sin compartir el estado entre ejecuciones del flujo.

Los flujos pueden transformarse según el tiempo, además de según el contenido. throttle limita la velocidad de emisión, groupedWithin agrupa por cantidad o por tiempo transcurrido, y takeWithin limita la duración.

Estos operadores son esenciales para limitar la velocidad de las API externas.

Una excepción lanzada dentro de un operador hace que todo el flujo falle de forma predeterminada. Una estrategia de supervisión puede hacer que, en su lugar, se use resume (descartar el elemento incorrecto) o restart (reiniciar la etapa).

Asocie la estrategia al Flow mediante withAttributes.

Los Flows pequeños se pueden combinar en otros más grandes mediante via, lo que produce un único Flow reutilizable. Así, cada transformación se mantiene enfocada y se puede probar de forma independiente.

El Flow compuesto tiene el tipo de entrada del primero y el tipo de salida del último.

Considere las transformaciones asíncronas y sus garantías de orden.

Ha explorado operadores de transformación: map/filter elemento a elemento, mapConcat de uno a muchos, agrupación con grouped, acumulación con scan y fold, y trabajo asíncrono mediante mapAsync.

También ha visto transformaciones con estado, operadores basados en el tiempo como throttle, estrategias de supervisión para errores y la composición de Flows con via. A continuación: cómo la contrapresión mantiene seguras estas etapas.