aboutsummaryrefslogblamecommitdiffhomepage
path: root/client/src/app/shared/rxjs/zone.ts
blob: 74eed7032dacab01e76fb34ac5c953acc4c72f42 (plain) (tree)







































                                                                                   
import { SchedulerLike, Subscription } from 'rxjs'
import { NgZone } from '@angular/core'

class LeaveZoneScheduler implements SchedulerLike {
  constructor (private zone: NgZone, private scheduler: SchedulerLike) {
  }

  schedule (...args: any[]): Subscription {
    return this.zone.runOutsideAngular(() =>
      this.scheduler.schedule.apply(this.scheduler, args)
    )
  }

  now (): number {
    return this.scheduler.now()
  }
}

class EnterZoneScheduler implements SchedulerLike {
  constructor (private zone: NgZone, private scheduler: SchedulerLike) {
  }

  schedule (...args: any[]): Subscription {
    return this.zone.run(() =>
      this.scheduler.schedule.apply(this.scheduler, args)
    )
  }

  now (): number {
    return this.scheduler.now()
  }
}

export function leaveZone (zone: NgZone, scheduler: SchedulerLike): SchedulerLike {
  return new LeaveZoneScheduler(zone, scheduler)
}

export function enterZone (zone: NgZone, scheduler: SchedulerLike): SchedulerLike {
  return new EnterZoneScheduler(zone, scheduler)
}