RxPY - Combinando Operadores

combinar o último

Este operador criará uma tupla, para o observável dado como entrada.

Sintaxe

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

Parâmetros

Observável: Um observável.

Valor de retorno

Ele retorna um observável com os valores do observável de origem convertidos em uma tupla.

Exemplo

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)))

Resultado

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)

fundir

Este operador irá mesclar dados observáveis.

Sintaxe

merge(observable)

Parâmetros

Observável: um observável.

Valor de retorno

Ele retornará um observável com uma sequência dos observáveis fornecidos.

Exemplo

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)))

Resultado

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

começar com

Este operador pegará os valores fornecidos e adicionará no início do retorno observável de origem a sequência completa.

Sintaxe

start_with(values)

Parâmetros

valores: os valores que você deseja prefixar no início.

Valor de retorno

Ele retorna um observável com valores dados prefixados no início, seguido pelos valores do observável de origem.

Exemplo

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

Resultado

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

fecho eclair

Este operador retorna um observável com valores em forma de tupla, que é formado tomando o primeiro valor do observável fornecido e assim por diante.

Sintaxe

zip(observable1, observable2...)

Parâmetros

Observável: um observável

Valor de retorno

Ele retorna um observável com valores no formato de tupla.

Exemplo

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)))

Resultado

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