La salida de este programa es: Crear el objeto Observable Configurar observadores/suscriptores Lambda Recibido 2 Lambda Recibido 3 Lambda Recibido 5 Lambda Recibido 7 Función recibida 2 Función Recibida 3 Función Recibida 5 Función recibida 7 Objeto recibido 2 Objeto recibido 3 Objeto recibido 5 Objeto recibido 7 Flujo de datos completado Recibido el_próximo 2 Recibido el_próximo 3 Recibido el_próximo 5 Recibido el_próximo 7 Notificación completada recibida Observe cómo a cada uno de los suscriptores se le envían todos los datos antes que al próximo suscriptor se envían sus datos (este es el comportamiento predeterminado de RxPy de subproceso único). 36.5 Materias en RxPy Un sujeto es a la vez un observador y un observable. Esto permite que un sujeto reciba un elemento de datos y luego volver a publicar esos datos o los datos derivados de ellos. Por ejemplo, imagina un sujeto que recibe datos de cotizaciones bursátiles publicados por una fuente externa (a la organización que recibe los datos). Este tema podría agregue una marca de tiempo y una ubicación de origen a los datos antes de volver a publicarlos en otros observadores internos. Sin embargo, hay una diferencia sutil que debe tenerse en cuenta entre un Sujeto y un simple Observable. Una suscripción a un Observable causará un independiente ejecución del Observable cuando se publican los datos. Fíjate cómo en el anterior sección todos los mensajes fueron enviados a un observador específico antes del siguiente observador se envió ningún dato en absoluto. Sin embargo, un Sujeto comparte la acción de publicación con todos los suscriptores y por lo tanto, todos recibirán el mismo elemento de datos en una cadena antes del siguiente dato artículo. En la jerarquía de clases, la clase Sujeto es una subclase directa del Observador. clase. 36.4 Múltiples Suscriptores/Observadores 433