Отписаться в RxJS 6?

Question

У меня есть тест, и он работает, но если я попытаюсь установить активное значение на другое значение, тест будет прерван.Поэтому я хочу отменить подписку a (текущий активный Observable) перед выполнением любого другого тестирования:

let a:Observable<Todo> = store.observeActive(); 
a.subscribe(active=> {
  expect(active).toEqual(todo1);
});
a.unsubscribe();

Похоже, RxJS 6 больше не имеет unsubscribe() ... Мысли?

Follow Up

Итак, мы отменили подписку на ссылку Subscription, но есть ли причина, по которой разработчики не поместили метод unsubscribe в экземпляр объекта, который подписывается?

Answer 1

let a:Observable<Todo> = store.observeActive(); 
const subscription = a.subscribe(active=> {
  expect(active).toEqual(todo1);
});
subscription.unsubscribe();

Subscribe возвращает подписку, и вы отказываетесь от подписки.