Actualizacion maquina principal

[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / src / internal / scheduler / QueueAction.ts

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/scheduler/QueueAction.ts b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/scheduler/QueueAction.ts
new file mode 100644 (file)
index 0000000..b5a8b51
--- /dev/null
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/scheduler/QueueAction.ts
@@ -0,0 +1,44 @@
+import { AsyncAction } from './AsyncAction';
+import { Subscription } from '../Subscription';
+import { QueueScheduler } from './QueueScheduler';
+import { SchedulerAction } from '../types';
+
+/**
+ * We need this JSDoc comment for affecting ESDoc.
+ * @ignore
+ * @extends {Ignored}
+ */
+export class QueueAction<T> extends AsyncAction<T> {
+
+  constructor(protected scheduler: QueueScheduler,
+              protected work: (this: SchedulerAction<T>, state?: T) => void) {
+    super(scheduler, work);
+  }
+
+  public schedule(state?: T, delay: number = 0): Subscription {
+    if (delay > 0) {
+      return super.schedule(state, delay);
+    }
+    this.delay = delay;
+    this.state = state;
+    this.scheduler.flush(this);
+    return this;
+  }
+
+  public execute(state: T, delay: number): any {
+    return (delay > 0 || this.closed) ?
+      super.execute(state, delay) :
+      this._execute(state, delay) ;
+  }
+
+  protected requestAsyncId(scheduler: QueueScheduler, id?: any, delay: number = 0): any {
+    // If delay exists and is greater than 0, or if the delay is null (the
+    // action wasn't rescheduled) but was originally scheduled as an async
+    // action, then recycle as an async action.
+    if ((delay !== null && delay > 0) || (delay === null && this.delay > 0)) {
+      return super.requestAsyncId(scheduler, id, delay);
+    }
+    // Otherwise flush the scheduler starting with this action.
+    return scheduler.flush(this);
+  }
+}