Observable. Si el Sujeto estaba suscrito al Observable antes del Los observadores estaban suscritos al Sujeto, entonces todos los datos podrían haber sido publicado antes de que los Observadores se registraran en el Sujeto. La salida de este programa es: Configuración Asunto Recibido 2 Función recibida (2, datetime.datetime(2019, 5, 21, 17, 0, 2, 196372)) Lambda recibido (2, fecha y hora. fecha y hora (2019, 5, 21, 17, 0, 2, 196372)) Recibido el_siguiente (2, fechahora.fechahora(2019, 5, 21, 17, 0, 2, 196372)) Asunto Recibido 3 Función recibida (3, datetime.datetime(2019, 5, 21, 17, 0, 2, 196439)) Lambda recibido (3, fecha y hora. fecha y hora (2019, 5, 21, 17, 0, 2, 196439)) Recibido el_siguiente (3, fechahora.fechahora(2019, 5, 21, 17, 0, 2, 196439)) Asunto Recibido 5 Función recibida (5, datetime.datetime(2019, 5, 21, 17, 0, 2, 196494)) Lambda recibido (5, fecha y hora. fecha y hora (2019, 5, 21, 17, 0, 2, 196494)) Recibido el_siguiente (5, fechahora.fechahora(2019, 5, 21, 17, 0, 2, 196494)) Asunto Recibido 7 Función recibida (7, datetime.datetime(2019, 5, 21, 17, 0, 2, 196548)) Lambda recibido (7, datetime.datetime(2019, 5, 21, 17, 0, 2, 196548)) Recibido el_siguiente (7, datetime.datetime(2019, 5, 21, 17, 0, 2, 196548)) Flujo de datos completado Notificación completada recibida Hecho Como puede verse en esta salida, los números 2, 3, 5 y 7 son recibidos por todos los Observadores una vez que el Sujeto haya agregado la marca de tiempo. 36.6 Concurrencia de observadores Por defecto, RxPy usa un modelo de un solo subproceso; eso es Observables y Observadores ejecutar en el mismo hilo de ejecución. Sin embargo, esto es solo el valor predeterminado, ya que es el enfoque más simple. Es posible indicar que cuando un Observador se suscribe a un Observable que debe ejecutarse en un subproceso separado usando el parámetro de palabra clave del planificador en el 36.5 Materias en RxPy 435