diff options
Diffstat (limited to 'client/src/app/shared/video')
-rw-r--r-- | client/src/app/shared/video/infinite-scroller.directive.ts | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/client/src/app/shared/video/infinite-scroller.directive.ts b/client/src/app/shared/video/infinite-scroller.directive.ts index 1da02f60f..16e901c34 100644 --- a/client/src/app/shared/video/infinite-scroller.directive.ts +++ b/client/src/app/shared/video/infinite-scroller.directive.ts | |||
@@ -5,6 +5,7 @@ import 'rxjs/add/operator/distinctUntilChanged' | |||
5 | import 'rxjs/add/operator/filter' | 5 | import 'rxjs/add/operator/filter' |
6 | import 'rxjs/add/operator/map' | 6 | import 'rxjs/add/operator/map' |
7 | import 'rxjs/add/operator/startWith' | 7 | import 'rxjs/add/operator/startWith' |
8 | import 'rxjs/add/operator/throttleTime' | ||
8 | import { fromEvent } from 'rxjs/observable/fromEvent' | 9 | import { fromEvent } from 'rxjs/observable/fromEvent' |
9 | 10 | ||
10 | @Directive({ | 11 | @Directive({ |
@@ -37,6 +38,7 @@ export class InfiniteScrollerDirective implements OnInit { | |||
37 | initialize () { | 38 | initialize () { |
38 | const scrollObservable = fromEvent(window, 'scroll') | 39 | const scrollObservable = fromEvent(window, 'scroll') |
39 | .startWith(true) | 40 | .startWith(true) |
41 | .throttleTime(200) | ||
40 | .map(() => ({ current: window.scrollY, maximumScroll: document.body.clientHeight - window.innerHeight })) | 42 | .map(() => ({ current: window.scrollY, maximumScroll: document.body.clientHeight - window.innerHeight })) |
41 | 43 | ||
42 | // Scroll Down | 44 | // Scroll Down |
@@ -49,7 +51,6 @@ export class InfiniteScrollerDirective implements OnInit { | |||
49 | return res | 51 | return res |
50 | }) | 52 | }) |
51 | .filter(({ current, maximumScroll }) => maximumScroll <= 0 || (current / maximumScroll) > this.decimalLimit) | 53 | .filter(({ current, maximumScroll }) => maximumScroll <= 0 || (current / maximumScroll) > this.decimalLimit) |
52 | .debounceTime(200) | ||
53 | .distinct() | 54 | .distinct() |
54 | .subscribe(() => this.nearOfBottom.emit()) | 55 | .subscribe(() => this.nearOfBottom.emit()) |
55 | 56 | ||
@@ -65,13 +66,11 @@ export class InfiniteScrollerDirective implements OnInit { | |||
65 | .filter(({ current, maximumScroll }) => { | 66 | .filter(({ current, maximumScroll }) => { |
66 | return current !== 0 && (1 - (current / maximumScroll)) > this.decimalLimit | 67 | return current !== 0 && (1 - (current / maximumScroll)) > this.decimalLimit |
67 | }) | 68 | }) |
68 | .debounceTime(200) | ||
69 | .distinct() | 69 | .distinct() |
70 | .subscribe(() => this.nearOfTop.emit()) | 70 | .subscribe(() => this.nearOfTop.emit()) |
71 | 71 | ||
72 | // Page change | 72 | // Page change |
73 | scrollObservable | 73 | scrollObservable |
74 | .debounceTime(500) | ||
75 | .distinct() | 74 | .distinct() |
76 | .map(({ current }) => Math.max(1, Math.round((current + InfiniteScrollerDirective.PAGE_VIEW_TOP_MARGIN) / this.pageHeight))) | 75 | .map(({ current }) => Math.max(1, Math.round((current + InfiniteScrollerDirective.PAGE_VIEW_TOP_MARGIN) / this.pageHeight))) |
77 | .distinctUntilChanged() | 76 | .distinctUntilChanged() |