La clase Observer debe asegurarse de que los métodos implementados se adhieran a los Protocolo de observador (es decir, que las firmas de on_next(), on_completed () y on_error() son correctos). 36.4 Múltiples Suscriptores/Observadores Un Observable puede tener varios Observadores suscritos. En este caso cada uno de los Se envía a Observadores todos los datos publicados por el Observable. Múltiples observadores se puede registrar con un Observable llamando al método de suscripción múltiple veces. Por ejemplo, el siguiente programa tiene cuatro suscriptores además de función on_error y on_completed registradas:

Crea un observable usando datos en una lista

observable = rx.from_list([2, 3, 5, 7]) clase PrimeNumberObserver: """ Una clase de observador """

def on_next(self, valor):
    print('Objeto recibido', valor)

def on_completed(self): print(‘Flujo de datos completado’) def on_error(self, error): imprimir(‘Ocurrió un error’, error) def prime_number_reporter(valor): print(‘Función Recibida’, valor) print(‘Configurar Observadores / Suscriptores’)

Suscribir una función lambda

observable.subscribe(valor lambda: print(‘Lambda recibido’, valor))

Suscribir una función con nombre

observable.subscribe(principal_numero_reportero)

Suscribir un objeto Observer

observable.subscribe(PrimeNumberObserver())

Use lambdas para configurar las tres funciones

observable.subscribe( on_next=valor lambda: print(‘Recibido el_siguiente’, valor), on_error=lambda exp: print(‘Ocurrió un error’, exp), on_completed=lambda: print(‘Recibido completado notificación’) ) 432 36 RxPy Observables, Observadores y Sujetos