diff --git a/frontend/src/app/components/television/television.component.html b/frontend/src/app/components/television/television.component.html
index c9caa54ef..7da6e2d38 100644
--- a/frontend/src/app/components/television/television.component.html
+++ b/frontend/src/app/components/television/television.component.html
@@ -7,7 +7,7 @@
         [height]="600"
         [left]="60"
         [right]="10"
-        [data]="mempoolStats && mempoolStats.length ? mempoolStats : null"
+        [data]="statsSubscription$ | async"
         [showZoom]="false"
       ></app-mempool-graph>
     </div>
diff --git a/frontend/src/app/components/television/television.component.ts b/frontend/src/app/components/television/television.component.ts
index ae5d9abfd..3c0c88ec8 100644
--- a/frontend/src/app/components/television/television.component.ts
+++ b/frontend/src/app/components/television/television.component.ts
@@ -4,39 +4,70 @@ import { OptimizedMempoolStats } from '../../interfaces/node-api.interface';
 import { StateService } from 'src/app/services/state.service';
 import { ApiService } from 'src/app/services/api.service';
 import { SeoService } from 'src/app/services/seo.service';
-import { Observable } from 'rxjs';
+import { ActivatedRoute } from '@angular/router';
+import { map, scan, startWith, switchMap, tap } from 'rxjs/operators';
+import { interval, merge, Observable } from 'rxjs';
+import { ChangeDetectionStrategy } from '@angular/core';
 
 @Component({
   selector: 'app-television',
   templateUrl: './television.component.html',
-  styleUrls: ['./television.component.scss']
+  styleUrls: ['./television.component.scss'],
+  changeDetection: ChangeDetectionStrategy.OnPush
 })
 export class TelevisionComponent implements OnInit {
 
   mempoolStats: OptimizedMempoolStats[] = [];
-  mempoolVsizeFeesData: any;
+  statsSubscription$: Observable<OptimizedMempoolStats[]>;
+  fragment: string;
 
   constructor(
     private websocketService: WebsocketService,
     private apiService: ApiService,
     private stateService: StateService,
     private seoService: SeoService,
+    private route: ActivatedRoute
   ) { }
 
+  refreshStats(time: number, fn: Observable<OptimizedMempoolStats[]>) {
+    return interval(time).pipe(startWith(0), switchMap(() => fn));
+  }
+
   ngOnInit() {
     this.seoService.setTitle($localize`:@@46ce8155c9ab953edeec97e8950b5a21e67d7c4e:TV view`);
     this.websocketService.want(['blocks', 'live-2h-chart', 'mempool-blocks']);
 
-    this.apiService.list2HStatistics$()
-      .subscribe((mempoolStats) => {
-        this.mempoolStats = mempoolStats;
-      });
-
-    this.stateService.live2Chart$
-      .subscribe((mempoolStats) => {
-        this.mempoolStats.unshift(mempoolStats);
-        this.mempoolStats = this.mempoolStats.slice(0, this.mempoolStats.length - 1);
-      });
+    this.statsSubscription$ = merge(
+      this.stateService.live2Chart$.pipe(map(stats => [stats])),
+      this.route.fragment
+        .pipe(
+          tap(fragment => { this.fragment = fragment ?? '2h'; }),
+          switchMap((fragment) => {
+            const minute = 60000; const hour = 3600000;
+            switch (fragment) {
+              case '24h': return this.apiService.list24HStatistics$();
+              case '1w': return this.refreshStats(5 * minute, this.apiService.list1WStatistics$());
+              case '1m': return this.refreshStats(30 * minute, this.apiService.list1MStatistics$());
+              case '3m': return this.refreshStats(2 * hour, this.apiService.list3MStatistics$());
+              case '6m': return this.refreshStats(3 * hour, this.apiService.list6MStatistics$());
+              case '1y': return this.refreshStats(8 * hour, this.apiService.list1YStatistics$());
+              case '2y': return this.refreshStats(8 * hour, this.apiService.list2YStatistics$());
+              case '3y': return this.refreshStats(12 * hour, this.apiService.list3YStatistics$());
+              default /* 2h */: return this.apiService.list2HStatistics$();
+            }
+          })
+        )
+    )
+    .pipe(
+      scan((mempoolStats, newStats) => {
+        if (newStats.length > 1) {
+          mempoolStats = newStats;
+        } else if (['2h', '24h'].includes(this.fragment)) {
+          mempoolStats.unshift(newStats[0]);
+          mempoolStats = mempoolStats.slice(0, mempoolStats.length - 1);
+        }
+        return mempoolStats;
+      })
+    );
   }
-
 }