El operador rx.operators.flat_map() también aplica una función a cada elemento de datos, pero luego aplica una operación de aplanamiento al resultado. Por ejemplo, si el resultado es una lista de listas, entonces flat_map aplanará esto en una sola lista. En esta sección nos se centrará en el operador rx.operators.map(). El operador rx.operators.map() permite aplicar una función a todos elementos de datos generados por un Observable. Luego se devuelve el resultado de esta función. como resultado de los operadores map() Observable. La función se suele utilizar para realizar alguna forma de transformación de los datos que se le suministran. Esto podría ser sumando uno a todos los valores enteros, convirtiendo el formato de los datos de XML a JSON, enriqueciendo los datos con información adicional como la hora en que se adquirido y quién proporcionó los datos, etc. En el ejemplo dado a continuación, estamos transformando el conjunto de valores enteros manipulado por el Observable original en cadenas. En el diagrama estas cadenas incluya comillas alrededor de ellos para resaltar que, de hecho, son una cadena: Esto es típico del uso de un operador de transformación; eso es cambiar los datos de un formato a otro o para añadir información a los datos. El código utilizado para implementar este escenario se proporciona a continuación. Tenga en cuenta el uso de la pipe() para aplicar el operador al flujo de datos generado por el Observable:

Aplicar una transformación a una fuente de datos para convertir

números enteros en cadenas

importar rx de operadores de importación rx como op

Configure una fuente con una función de mapa

fuente = rx.from_list([2, 3, 5, 7]).pipe( op.map(valor lambda: “’” + str(valor) + “’”) )

Suscribir una función lambda

source.subscribe(valor lambda: print(‘Lambda recibido’, valor, ’ es una cadena ‘, es instancia (valor, str))) 442 37 Operadores RxPy