Is there any way to check if source is subscribed?

Question

Just as the title says, in Angular 2, is there any way to check if source is already subscribed? Because I have to check it before using

this.subscription.unsubscribe();

This is my code:

this.Source = Rx.Observable.timer(startTime, 60000).timeInterval().pluck('interval');

this.Subscription = this.Source
  .subscribe(data => { something }

and then I want to be sure that it is subscribed before calling unsubscribe()

Solution 1

It seems you can check whether the subscription is closed with

this.subscription.closed

indicate whether this Subscription has already been unsubscribed.

Solution 2

I had a similar case, I had a if condition with one optional subscribe:

if (languageIsSet) {
   // do things...
} else {
   this.langSub = this.langService.subscribe(lang => { 
      // do things...
   });
}

If you want to call unsubscribe safely (you don't know if is subscribed or not), just initialize the subscription with EMPTY instance:

private langSub: Subscription = Subscription.EMPTY;

Now you can unsubscribe without errors.

Solution 3

You can check if Subject has observers because it has a public property observers.

With Observables you can't because they don't typically have arrays of observers. Only if you've multicasted them via a Subject with the multicast() operator for example.

Maybe if you could describe your use case in more detail I'll be able to give you better advice.

const source = ...;
let subscribed = false;

Rx.Observable.defer(() => {
    subscribed = true;
    return source.finally(() => { subscribed = false });
})

Solution 4

As I can see in your code you always create a subscription.

So if you created subscriptions object it means subscription exists and you can unsubscribe.

It Still a bit not clear why you need to check is any subsection exist

Btw. unsubscribe() method checking is subscription closed or not. Subscription is closed if somebody called unsubscribe() or observable is compleated

View more solutions

Comments

[martin]

You want to check if Observable has observers?

[Sergey Karavaev]

It is still unclear why exactly you want to check for subscription before calling unsubscribe. You can always initialize your subscription with an empty subscription instance, e.g. this.subscription = Subscription.EMPTY, calling unsubscribe on it is safe.

[Max Koretskyi]

Only if you've multicasted - but that in effect still returns a subject, correct?