método de suscripción(). A esta palabra clave se le asigna un programador apropiado, como el rx.concurrency.NewThreadScheduler. Este programador asegurará que el Observer ejecuta en un subproceso separado. Para ver la diferencia, observe los siguientes dos programas. La principal diferencia entre los programas es el uso de planificadores específicos: importar rx Observable = rx.from_list([2, 3, 5]) observable.subscribe(lambda v: print(‘Lambda1 Recibido’, v)) observable.subscribe(lambda v: print(‘Lambda2 Recibido’, v)) observable.subscribe(lambda v: print(‘Lambda3 Recibido’, v)) El resultado de esta primera versión se muestra a continuación: Lambda1 Recibido 2 Lambda1 Recibido 3 Lambda1 Recibido 5 Lambda2 Recibido 2 Lambda2 Recibido 3 Lambda2 Recibido 5 Lambda3 Recibido 2 Lambda3 Recibido 3 Lambda3 Recibido 5 El método subscribe() toma un parámetro de palabra clave opcional llamado planificador que permite proporcionar un objeto planificador. Ahora, si especificamos algunos programadores diferentes, veremos que el efecto es ejecutar los observadores simultáneamente con la salida resultante entretejida: importar rx desde rx.concurrency import NewThreadScheduler, ThreadPoolScheduler, ImmediateScheduler Observable = rx.from_list([2, 3, 5]) observable.subscribe(lambda v: print(‘Lambda1 Recibido’, v), planificador=ThreadPoolScheduler(3)) observable.subscribe(lambda v: print(‘Lambda2 Recibido’, v), planificador=ProgramadorInmediato()) observable.subscribe(lambda v: print(‘Lambda3 Recibido’, v), planificador = NewThreadScheduler())

Como el Observable se ejecuta en un subproceso separado, es necesario

asegurar que el hilo principal no termine

input(‘Presiona enter para terminar’) 436 36 RxPy Observables, Observadores y Sujetos