RxPY - Combinaison d'opérateurs

combine_latest

Cet opérateur créera un tuple, pour l'observable donnée en entrée.

Syntaxe

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

Paramètres

Observable: Un observable.

Valeur de retour

Il renvoie une observable avec les valeurs de l'observable source converties en tuple.

Exemple

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

Production

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)

fusionner

Cet opérateur fusionnera des observables données.

Syntaxe

merge(observable)

Paramètres

Observable: un observable.

Valeur de retour

Il renverra une observable avec une séquence parmi les observables données.

Exemple

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

Production

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

Commencer avec

Cet opérateur prendra les valeurs données, et ajoutera au début de l'observable source renvoyer la séquence complète.

Syntaxe

start_with(values)

Paramètres

values: les valeurs que vous souhaitez préfixer au début.

Valeur de retour

Il renvoie une observable avec des valeurs données préfixées au début, suivies des valeurs de l'observable source.

Exemple

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

Production

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

Zip *: français

Cet opérateur renvoie une observable avec des valeurs sous forme de tuple, qui est formée en prenant la première valeur de l'observable donnée et ainsi de suite.

Syntaxe

zip(observable1, observable2...)

Paramètres

Observable: un observable

Valeur de retour

Il renvoie une observable avec des valeurs au format tuple.

Exemple

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

Production

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)