El resultado de este programa se presenta a continuación: 2,3,5,7,10,11,12, Observe en la salida la forma en que los datos se mantienen en los Observables originales está entrelazado en la salida del Observable generado por el operador merge(). 37.7 Operadores de filtrado Hay varios operadores en esta categoría, incluidos rx.operators.filter (), rx.operators.first(), rx.operators.last() y rx.opera- tors.distinct(). El operador filter() solo permite que esos elementos de datos pasen a través de ese pase alguna expresión de prueba definida por la función pasada al filtro. Esta función debe devolver Verdadero o Falso. Cualquier elemento de datos que haga que la función devuelva True se deja pasar a través del filtro. Por ejemplo, supongamos que la función que se pasa a filter() está diseñada para permitir solo el paso de números pares. Si el flujo de datos contiene los números 2, 3, 5, 7, 4, 9 y 8, entonces el filtro() solo emitirá los números 2, 4 y 8. Esto es ilustrado a continuación: El siguiente código implementa el escenario anterior:

Fuente de filtro para números pares

importar rx de operadores de importación rx como op

Configure una fuente con un filtro

fuente = rx.from_list([2, 3, 5, 7, 4, 9, 8]).pipe( op.filter(valor lambda: valor % 2 == 0) )

Suscribir una función lambda

source.subscribe(valor lambda: print(‘Lambda recibido’, valor)) En el código anterior, el operador rx.operators.filter() toma una lambda función que verificará si el valor actual es par o no (tenga en cuenta que esto podría haber sido una función con nombre o un método en un objeto, etc.). Se aplica al flujo de datos. generado por el Observable usando el método pipe(). La salida generada por este ejemplo es: 444 37 Operadores RxPy