.map(handle => this.userSubscriptionService.addSubscription(handle))
forkJoin(observableBatch)
- .subscribe(
- () => {
+ .subscribe({
+ next: () => {
this.notifier.success(
this.account
? $localize`Subscribed to all current channels of ${this.account.displayName}. You will be notified of all their new videos.`
)
},
- err => this.notifier.error(err.message)
- )
+ error: err => this.notifier.error(err.message)
+ })
}
unsubscribe () {
this.notifier.success(
this.account
? $localize`Unsubscribed from all channels of ${this.account.nameWithHost}`
- : $localize`Unsubscribed from ${this.videoChannels[ 0 ].nameWithHost}`,
+ : $localize`Unsubscribed from ${this.videoChannels[0].nameWithHost}`,
$localize`Unsubscribed`
)
subscribeStatus (subscribed: boolean) {
const accumulator: string[] = []
- for (const [key, value] of this.subscribed.entries()) {
+ for (const [ key, value ] of this.subscribed.entries()) {
if (value === subscribed) accumulator.push(key)
}
merge(
this.userSubscriptionService.listenToSubscriptionCacheChange(handle),
this.userSubscriptionService.doesSubscriptionExist(handle)
- ).subscribe(
- res => this.subscribed.set(handle, res),
+ ).subscribe({
+ next: res => this.subscribed.set(handle, res),
- err => this.notifier.error(err.message)
- )
+ error: err => this.notifier.error(err.message)
+ })
}
}
}