Lambda Recibido 2 Lambda Recibido 4 Lambda Recibido 8 Los operadores first() y last() emiten solo el primer y último elemento de datos publicado por el Observable. El operador distint() suprime los elementos duplicados que publica el Observable. Por ejemplo, en la siguiente lista utilizada como datos para el Observable, los números 2 y 3 están duplicados:

Usar distinto para suprimir duplicados

fuente = rx.from_list([2, 3, 5, 2, 4, 3, 2]).pipe( op.distinto() )

Suscribir una función lambda

source.subscribe(valor lambda: print(‘Recibido’, valor)) Sin embargo, cuando el programa genera la salida, todos los duplicados se han eliminado. suprimido: Recibido 2 Recibido 3 Recibido 5 Recibido 4 37.8 Operadores matemáticos Los operadores matemáticos y agregados realizan cálculos en el flujo de datos proporcionada por un Observable. Por ejemplo, rx.operators.average() El operador se puede utilizar para calcular el promedio de un conjunto de números publicados por un Observable. Del mismo modo, rx.operators.max() puede seleccionar el valor máximo, rx.operators.min() el valor mínimo y rx.operators.sum() sumar todos los números publicados etc. Se da un ejemplo usando el operador rx.operators.sum() golpe:

Ejemplo de sumar todos los valores en un flujo de datos

importar rx de operadores de importación rx como op

Configure una fuente y aplique la suma

rx.from_list([2, 3, 5, 7]).pipe( op.suma() ).subscribe(lambda v: imprimir(v)) 37.7 Operadores de filtrado 445