From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- .../esm/internal/scheduler/AnimationFrameAction.js | 29 ++++++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 node_modules/rxjs/dist/esm/internal/scheduler/AnimationFrameAction.js (limited to 'node_modules/rxjs/dist/esm/internal/scheduler/AnimationFrameAction.js') diff --git a/node_modules/rxjs/dist/esm/internal/scheduler/AnimationFrameAction.js b/node_modules/rxjs/dist/esm/internal/scheduler/AnimationFrameAction.js new file mode 100644 index 0000000..f896a06 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduler/AnimationFrameAction.js @@ -0,0 +1,29 @@ +import { AsyncAction } from './AsyncAction'; +import { animationFrameProvider } from './animationFrameProvider'; +export class AnimationFrameAction extends AsyncAction { + constructor(scheduler, work) { + super(scheduler, work); + this.scheduler = scheduler; + this.work = work; + } + requestAsyncId(scheduler, id, delay = 0) { + if (delay !== null && delay > 0) { + return super.requestAsyncId(scheduler, id, delay); + } + scheduler.actions.push(this); + return scheduler._scheduled || (scheduler._scheduled = animationFrameProvider.requestAnimationFrame(() => scheduler.flush(undefined))); + } + recycleAsyncId(scheduler, id, delay = 0) { + var _a; + if (delay != null ? delay > 0 : this.delay > 0) { + return super.recycleAsyncId(scheduler, id, delay); + } + const { actions } = scheduler; + if (id != null && id === scheduler._scheduled && ((_a = actions[actions.length - 1]) === null || _a === void 0 ? void 0 : _a.id) !== id) { + animationFrameProvider.cancelAnimationFrame(id); + scheduler._scheduled = undefined; + } + return undefined; + } +} +//# sourceMappingURL=AnimationFrameAction.js.map \ No newline at end of file -- cgit v1.2.3