RxPY - Combinazione di operatori

combinare_latest

Questo operatore creerà una tupla, per l'osservabile dato come input.

Sintassi

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

Parametri

Osservabile: un osservabile.

Valore di ritorno

Restituisce un osservabile con i valori dell'osservabile sorgente convertiti in una tupla.

Esempio

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

Produzione

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)

unire

Questo operatore unirà dati osservabili.

Sintassi

merge(observable)

Parametri

Osservabile: un osservabile.

Valore di ritorno

Restituirà un osservabile con una sequenza dalle osservabili date.

Esempio

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

Produzione

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

iniziare con

Questo operatore prenderà i valori dati e aggiungerà all'inizio della fonte osservabile restituire l'intera sequenza.

Sintassi

start_with(values)

Parametri

valori: i valori che si desidera anteporre all'inizio.

Valore di ritorno

Restituisce un osservabile con valori dati prefissati all'inizio seguiti dai valori osservabili dalla sorgente.

Esempio

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

Produzione

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

cerniera lampo

Questo operatore restituisce un osservabile con valori in una forma tupla, che è formato prendendo il primo valore dell'osservabile dato e così via.

Sintassi

zip(observable1, observable2...)

Parametri

Osservabile: un osservabile

Valore di ritorno

Restituisce un osservabile con valori in formato tupla.

Esempio

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

Produzione

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)