client/src/app/shared/rxjs/zone.ts

   1 import { SchedulerLike, Subscription } from 'rxjs'
   2 import { NgZone } from '@angular/core'
   3
   4 class LeaveZoneScheduler implements SchedulerLike {
   5   constructor (private zone: NgZone, private scheduler: SchedulerLike) {
   6   }
   7
   8   schedule (...args: any[]): Subscription {
   9     return this.zone.runOutsideAngular(() =>
  10       this.scheduler.schedule.apply(this.scheduler, args)
  11     )
  12   }
  13
  14   now (): number {
  15     return this.scheduler.now()
  16   }
  17 }
  18
  19 class EnterZoneScheduler implements SchedulerLike {
  20   constructor (private zone: NgZone, private scheduler: SchedulerLike) {
  21   }
  22
  23   schedule (...args: any[]): Subscription {
  24     return this.zone.run(() =>
  25       this.scheduler.schedule.apply(this.scheduler, args)
  26     )
  27   }
  28
  29   now (): number {
  30     return this.scheduler.now()
  31   }
  32 }
  33
  34 export function leaveZone (zone: NgZone, scheduler: SchedulerLike): SchedulerLike {
  35   return new LeaveZoneScheduler(zone, scheduler)
  36 }
  37
  38 export function enterZone (zone: NgZone, scheduler: SchedulerLike): SchedulerLike {
  39   return new EnterZoneScheduler(zone, scheduler)
  40 }