aboutsummaryrefslogtreecommitdiffhomepage
path: root/client/src/app/shared/video
diff options
context:
space:
mode:
Diffstat (limited to 'client/src/app/shared/video')
-rw-r--r--client/src/app/shared/video/infinite-scroller.directive.ts5
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'
5import 'rxjs/add/operator/filter' 5import 'rxjs/add/operator/filter'
6import 'rxjs/add/operator/map' 6import 'rxjs/add/operator/map'
7import 'rxjs/add/operator/startWith' 7import 'rxjs/add/operator/startWith'
8import 'rxjs/add/operator/throttleTime'
8import { fromEvent } from 'rxjs/observable/fromEvent' 9import { 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()