RxPY - Operadores de combinación

combine_latest

Este operador creará una tupla, para el observable dado como entrada.

Sintaxis

combine_latest(observable1,observable2,.....)

Parámetros

Observable: un observable.

Valor devuelto

Devuelve un observable con los valores del observable de origen convertidos en una tupla.

Ejemplo

from rx import of, operators as op
from datetime import date
test = of(1,2,3,4,5,6)
test2 = of(11,12,13,14,15,16)
test3 = of(111,112,113,114,115,116)
sub1 = test.pipe(
   op.combine_latest(test2, test3)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)))

Salida

E:\pyrx>python testrx.py
The value is (6, 16, 111)
The value is (6, 16, 112)
The value is (6, 16, 113)
The value is (6, 16, 114)
The value is (6, 16, 115)
The value is (6, 16, 116)

unir

Este operador fusionará los observables dados.

Sintaxis

merge(observable)

Parámetros

Observable: un observable.

Valor devuelto

Devolverá un observable con una secuencia de los observables dados.

Ejemplo

from rx import of, operators as op
from datetime import date
test = of(1,2,3,4,5,6)
test2 = of(11,12,13,14,15,16)
sub1 = test.pipe(
   op.merge(test2)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)))

Salida

E:\pyrx>python testrx.py
The value is 1
The value is 2
The value is 3
The value is 4
The value is 5
The value is 6
The value is 11
The value is 12
The value is 13
The value is 14
The value is 15
The value is 16

Empezar con

Este operador tomará los valores dados y los agregará al comienzo de la fuente observable y devolverá la secuencia completa.

Sintaxis

start_with(values)

Parámetros

valores: los valores que desea prefijar al principio.

Valor devuelto

Devuelve un observable con valores dados prefijados al principio seguido de los valores del observable de origen.

Ejemplo

from rx import of, operators as op
from datetime import date
test = of(1,2,3,4,5,6)
sub1 = test.pipe(
   op.start_with(-2,-1,0)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)))xExample

Salida

E:\pyrx>python testrx.py
The value is -2
The value is -1
The value is 0
The value is 1
The value is 2
The value is 3
The value is 4
The value is 5
The value is 6

Código Postal

Este operador devuelve un observable con valores en forma de tupla, que se forma tomando el primer valor del observable dado y así sucesivamente.

Sintaxis

zip(observable1, observable2...)

Parámetros

Observable: un observable

Valor devuelto

Devuelve un observable con valores en formato de tupla.

Ejemplo

from rx import of, operators as op
from datetime import date
test = of(1,2,3,4,5,6)
test1 = of(4,8,12,16,20)
test2 = of(5,10,15,20,25)
sub1 = test.pipe(
   op.zip(test1, test2)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)))

Salida

E:\pyrx>python testrx.py
The value is (1, 4, 5)
The value is (2, 8, 10)
The value is (3, 12, 15)
The value is (4, 16, 20)
The value is (5, 20, 25)

↰ Previous page