From b7819090de8ced71e5f9c5773c575ab627a148e4 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Fri, 3 Jan 2020 15:01:17 +0100 Subject: Move watch later logic in miniature --- client/src/app/shared/video-playlist/video-playlist.service.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'client/src/app/shared/video-playlist') diff --git a/client/src/app/shared/video-playlist/video-playlist.service.ts b/client/src/app/shared/video-playlist/video-playlist.service.ts index fc3b77b2a..d78fdc09f 100644 --- a/client/src/app/shared/video-playlist/video-playlist.service.ts +++ b/client/src/app/shared/video-playlist/video-playlist.service.ts @@ -1,4 +1,4 @@ -import { bufferTime, catchError, filter, first, map, share, switchMap } from 'rxjs/operators' +import { bufferTime, catchError, distinctUntilChanged, filter, first, map, share, switchMap } from 'rxjs/operators' import { Injectable } from '@angular/core' import { Observable, ReplaySubject, Subject } from 'rxjs' import { RestExtractor } from '../rest/rest-extractor.service' @@ -30,7 +30,6 @@ export class VideoPlaylistService { // Use a replay subject because we "next" a value before subscribing private videoExistsInPlaylistSubject: Subject = new ReplaySubject(1) private readonly videoExistsInPlaylistObservable: Observable - private cachedWatchLaterPlaylists: VideoPlaylist[] constructor ( private authHttp: HttpClient, @@ -39,6 +38,7 @@ export class VideoPlaylistService { private restService: RestService ) { this.videoExistsInPlaylistObservable = this.videoExistsInPlaylistSubject.pipe( + distinctUntilChanged(), bufferTime(500), filter(videoIds => videoIds.length !== 0), switchMap(videoIds => this.doVideosExistInPlaylist(videoIds)), @@ -224,7 +224,7 @@ export class VideoPlaylistService { let params = new HttpParams() params = this.restService.addObjectParams(params, { videoIds }) - return this.authHttp.get(url, { params }) + return this.authHttp.get(url, { params, headers: { ignoreLoadingBar: '' } }) .pipe(catchError(err => this.restExtractor.handleError(err))) } } -- cgit v1.2.3