initial commit: scaffolding

1 files changed, 29 insertions, 0 deletions

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