subscription.unsubscribe.js

const subject = new Rx.Subject();

const subscription = 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)

/* Cancelando a "inscrição" no Stream de eventos emitidos pela instância de `subject`.
Eventos poderão ser inseridos no Stream de subject, só não serão mais "escutados" para esse contexto*/
subscription.unsubscribe()