Reactive programming in Python con RxPy

RxPy è una implementazione per Python di ReactiveX, un API per la programmazione asincrona.

In questo articolo vediamo un esempio del suo utilizzo.

Prima di tutto installiamolo con pip:

pip install reactivex

Qui sotto un paio di esempi:

from reactivex import of, operators

src = of("uno", "due", "tre", "quattro")
src.subscribe(
    on_next=lambda i: print("INSERITO {0}".format(i)),
    on_error=lambda e: print("ERRORE: {0}".format(e)),
    on_completed=lambda: print("FINE!"),
)

print("-----")

composed = src.pipe(
    operators.map(lambda s: len(s)),
    operators.filter(lambda i: i > 3)
)
composed.subscribe(lambda value: print("LUNGHEZZA {0}".format(value)))

Nel primo blocco ci limitiamo a indicare i vari eventi man mano che la subscribe scorre gli elementi.

Poi eseguiamo un filtro sulla lunghezza delle stringhe.

Enjoy!