source: trip-planner-front/node_modules/rxjs/_esm2015/internal/scheduler/VirtualTimeScheduler.js

Last change on this file was 6a3a178, checked in by Ema <ema_spirova@…>, 3 years ago

initial commit

  • Property mode set to 100644
File size: 2.4 KB
Line 
1import { AsyncAction } from './AsyncAction';
2import { AsyncScheduler } from './AsyncScheduler';
3export class VirtualTimeScheduler extends AsyncScheduler {
4 constructor(SchedulerAction = VirtualAction, maxFrames = Number.POSITIVE_INFINITY) {
5 super(SchedulerAction, () => this.frame);
6 this.maxFrames = maxFrames;
7 this.frame = 0;
8 this.index = -1;
9 }
10 flush() {
11 const { actions, maxFrames } = this;
12 let error, action;
13 while ((action = actions[0]) && action.delay <= maxFrames) {
14 actions.shift();
15 this.frame = action.delay;
16 if (error = action.execute(action.state, action.delay)) {
17 break;
18 }
19 }
20 if (error) {
21 while (action = actions.shift()) {
22 action.unsubscribe();
23 }
24 throw error;
25 }
26 }
27}
28VirtualTimeScheduler.frameTimeFactor = 10;
29export class VirtualAction extends AsyncAction {
30 constructor(scheduler, work, index = scheduler.index += 1) {
31 super(scheduler, work);
32 this.scheduler = scheduler;
33 this.work = work;
34 this.index = index;
35 this.active = true;
36 this.index = scheduler.index = index;
37 }
38 schedule(state, delay = 0) {
39 if (!this.id) {
40 return super.schedule(state, delay);
41 }
42 this.active = false;
43 const action = new VirtualAction(this.scheduler, this.work);
44 this.add(action);
45 return action.schedule(state, delay);
46 }
47 requestAsyncId(scheduler, id, delay = 0) {
48 this.delay = scheduler.frame + delay;
49 const { actions } = scheduler;
50 actions.push(this);
51 actions.sort(VirtualAction.sortActions);
52 return true;
53 }
54 recycleAsyncId(scheduler, id, delay = 0) {
55 return undefined;
56 }
57 _execute(state, delay) {
58 if (this.active === true) {
59 return super._execute(state, delay);
60 }
61 }
62 static sortActions(a, b) {
63 if (a.delay === b.delay) {
64 if (a.index === b.index) {
65 return 0;
66 }
67 else if (a.index > b.index) {
68 return 1;
69 }
70 else {
71 return -1;
72 }
73 }
74 else if (a.delay > b.delay) {
75 return 1;
76 }
77 else {
78 return -1;
79 }
80 }
81}
82//# sourceMappingURL=VirtualTimeScheduler.js.map
Note: See TracBrowser for help on using the repository browser.