RxJS e o Padrão Observer

rxjs-padraoobserver.js

const subject = new Rx.Subject();

/* Observers são consumidores dos valores entregues pelos Subjects (ou Observables).
São simplemente objetos com três callbacks, um para cada tipo de notificação 
que pode ser entregue pelo Subject/Observable: next, error e complete.*/
const observerA = {
  next: valor => console.log(`observerA consumindo informação: ${valor}`),
  error: err => console.log('observerA recebendo uma notificação de erro'),
  complete: () => console.log('observerA sendo informando que o subject foi finalizado')
}

const subscription = subject.subscribe(observerA)

subject.subscribe({
  next: valor => console.log(`observerB consumindo informação: ${valor}`),
  error: err => console.log('observerB recebendo uma notificação de erro')
})

subject.next(1)
subject.complete()

// Após finalizando, o subject não pode mais emitir notificações.
subject.next(2) // Valor será "ignorado".
subscription.unsubscribe()