36.3 Observadores en RxPy Podemos agregar un Observador a un Observable usando el método subcribe(). Este método se puede suministrar con una función lambda, una función con nombre o un objeto cuya clase implementa el protocolo Observer. Por ejemplo, la forma más sencilla de crear un observador es usar una función lambda:

Suscribir una función lambda

observable.subscribe(valor lambda: print(‘Lambda recibido’, valor)) Cuando el Observable publique datos, se invocará la función lambda. Cada dato publicado se suministrará de forma independiente a la función. La salida de la suscripción anterior para el Observable anterior es: Lambda Recibido 2 Lambda Recibido 3 Lambda Recibido 5 Lambda Recibido 7 También podemos haber usado una función estándar o con nombre como observador: def prime_number_reporter(valor): print(‘Función Recibida’, valor)

Suscribir una función con nombre

observable.subscribe(principal_numero_reportero) Tenga en cuenta que es solo el nombre de la función que se usa con subscribe() método (ya que esto efectivamente pasa una referencia a la función en el método). Si ahora ejecutamos este código usando el Observable anterior, obtenemos: Función recibida 2 Función Recibida 3 Función Recibida 5 Función recibida 7 De hecho, el método subscribe() toma cuatro parámetros opcionales. estos son: • on_next Acción a invocar para cada elemento de datos generado por el Observable. • on_error Acción para invocar ante la terminación excepcional del Observable secuencia. • on_completed Acción para invocar tras la finalización correcta del Observable secuencia. • Observer El objeto que va a recibir notificaciones. Puedes suscribirte usando un observador o devoluciones de llamada, no ambos. 430 36 RxPy Observables, Observadores y Sujetos