@reactive-js/schedulers - npm Package Compare versions

Comparing version 0.0.11 to 0.0.12

dist/cjs/index.d.ts

 export { createPrioritySchedulerResource, PrioritySchedulerLike, PrioritySchedulerResourceLike, } from "./internal/priorityScheduler";
-export { createVirtualTimeSchedulerResource, VirtualTimeSchedulerLike, VirtualTimeSchedulerResourceLike, } from "./internal/virtualTimeScheduler";
+export { createVirtualTimeSchedulerResource, VirtualTimeSchedulerResourceLike, } from "./internal/virtualTimeScheduler";
 export { createSynchronousSchedulerResource } from "./internal/synchronousScheduler";
 export { createSchedulerWithPriority } from "./internal/schedulerWithPriority";
 export { AbstractScheduler, AbstractSchedulerResource, } from "./internal/abstractScheduler";

dist/cjs/internal/abstractScheduler.d.ts

@@ -18,5 +18,5 @@ import { DisposableLike, DisposableOrTeardown } from "@reactive-js/disposable";
     get isDisposed(): boolean;
-    add(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): void;
+    add(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): this;
     dispose(): void;
-    remove(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): void;
+    remove(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): this;
 }

dist/cjs/internal/abstractScheduler.js

@@ -56,2 +56,3 @@ "use strict";
         this.disposable.add(disposable, ...disposables);
+        return this;
     }
@@ -63,2 +64,3 @@ dispose() {
         this.disposable.remove(disposable, ...disposables);
+        return this;
     }
@@ -65,0 +67,0 @@ }

dist/cjs/internal/priorityScheduler.js

@@ -87,2 +87,3 @@ "use strict";
         this.disposable.add(disposable, ...disposables);
+        return this;
     }
@@ -94,2 +95,3 @@ dispose() {
         this.disposable.remove(disposable, ...disposables);
+        return this;
     }
@@ -96,0 +98,0 @@ schedule(continuation, priority, delay = 0) {

dist/cjs/internal/synchronousScheduler.js

@@ -7,10 +7,2 @@ "use strict";
 const shouldYieldTrue = () => true;
-const iteratorYield = {
-    done: false,
-    value: undefined,
-};
-const iteratorDone = {
-    done: true,
-    value: undefined,
-};
 class SynchronousSchedulerResource extends virtualTimeScheduler_1.AbstractVirtualTimeSchedulerResource {
@@ -30,18 +22,16 @@ constructor() {
     }
-    next() {
-        disposable_1.throwIfDisposed(this);
-        this.shouldYield = shouldYieldTrue;
-        if (this.queue.length > 0) {
-            const next = this.queue.shift();
+    step() {
+        const next = this.queue.shift();
+        if (next !== undefined) {
             next();
         }
-        return this.queue.length > 0 ? iteratorYield : iteratorDone;
+        return this.queue.length > 0;
     }
+    next() {
+        this.shouldYield = shouldYieldTrue;
+        return super.next();
+    }
     run() {
-        disposable_1.throwIfDisposed(this);
         this.shouldYield = shouldYieldFalse;
-        for (let next = this.queue.shift(); next !== undefined; next = this.queue.shift()) {
-            next();
-        }
-        this.dispose();
+        super.run();
     }
@@ -48,0 +38,0 @@ }

dist/cjs/internal/virtualTimeScheduler.d.ts

@@ -1,14 +0,13 @@
-import { SchedulerLike, SchedulerResourceLike } from "@reactive-js/scheduler";
+import { SchedulerResourceLike } from "@reactive-js/scheduler";
 import { AbstractSchedulerResource } from "./abstractScheduler";
-export interface VirtualTimeSchedulerLike extends SchedulerLike, Iterator<void> {
+export interface VirtualTimeSchedulerResourceLike extends SchedulerResourceLike, Iterator<void> {
     run(): void;
 }
-export interface VirtualTimeSchedulerResourceLike extends SchedulerResourceLike, VirtualTimeSchedulerLike {
-}
 export declare abstract class AbstractVirtualTimeSchedulerResource extends AbstractSchedulerResource {
-    abstract step(): boolean;
+    protected abstract step(): boolean;
     next(): IteratorResult<void>;
     return(): IteratorResult<void>;
     throw(e?: any): IteratorResult<void>;
+    run(): void;
 }
 export declare const createVirtualTimeSchedulerResource: (maxMicroTaskTicks?: number) => VirtualTimeSchedulerResourceLike;

dist/cjs/internal/virtualTimeScheduler.js

@@ -31,2 +31,7 @@ "use strict";
     }
+    run() {
+        disposable_1.throwIfDisposed(this);
+        while (this.step()) { }
+        this.dispose();
+    }
 }
@@ -40,3 +45,3 @@ exports.AbstractVirtualTimeSchedulerResource = AbstractVirtualTimeSchedulerResource;
 };
-class VirtualTimeSchedulerResourceImpl extends abstractScheduler_1.AbstractSchedulerResource {
+class VirtualTimeSchedulerResourceImpl extends AbstractVirtualTimeSchedulerResource {
     constructor(maxMicroTaskTicks) {
@@ -70,25 +75,17 @@ super();
     }
-    runNextTask() {
-        const { dueTime, callback, disposable, } = this.taskQueue.pop();
-        this._now = dueTime;
-        this.microTaskTicks = 0;
-        if (!disposable.isDisposed) {
-            callback();
-            disposable.dispose();
+    step() {
+        const task = this.taskQueue.pop();
+        if (task !== undefined) {
+            const { dueTime, callback, disposable } = task;
+            this._now = dueTime;
+            this.microTaskTicks = 0;
+            if (!disposable.isDisposed) {
+                callback();
+                disposable.dispose();
+            }
         }
+        return this.taskQueue.count > 0;
     }
-    next() {
-        disposable_1.throwIfDisposed(this);
-        this.runNextTask();
-        return this.taskQueue.count > 0 ? iteratorYield : iteratorDone;
-    }
-    run() {
-        disposable_1.throwIfDisposed(this);
-        while (this.taskQueue.count > 0) {
-            this.runNextTask();
-        }
-        this.dispose();
-    }
 }
 exports.createVirtualTimeSchedulerResource = (maxMicroTaskTicks = Number.MAX_SAFE_INTEGER) => new VirtualTimeSchedulerResourceImpl(maxMicroTaskTicks);
 //# sourceMappingURL=virtualTimeScheduler.js.map

dist/esm5/index.d.ts

 export { createPrioritySchedulerResource, PrioritySchedulerLike, PrioritySchedulerResourceLike, } from "./internal/priorityScheduler";
-export { createVirtualTimeSchedulerResource, VirtualTimeSchedulerLike, VirtualTimeSchedulerResourceLike, } from "./internal/virtualTimeScheduler";
+export { createVirtualTimeSchedulerResource, VirtualTimeSchedulerResourceLike, } from "./internal/virtualTimeScheduler";
 export { createSynchronousSchedulerResource } from "./internal/synchronousScheduler";
 export { createSchedulerWithPriority } from "./internal/schedulerWithPriority";
 export { AbstractScheduler, AbstractSchedulerResource, } from "./internal/abstractScheduler";

dist/esm5/internal/abstractScheduler.d.ts

@@ -18,5 +18,5 @@ import { DisposableLike, DisposableOrTeardown } from "@reactive-js/disposable";
     get isDisposed(): boolean;
-    add(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): void;
+    add(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): this;
     dispose(): void;
-    remove(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): void;
+    remove(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): this;
 }

dist/esm5/internal/abstractScheduler.js

@@ -53,2 +53,3 @@ import { createDisposable, createSerialDisposable, disposed, } from "@reactive-js/disposable";
         this.disposable.add(disposable, ...disposables);
+        return this;
     }
@@ -60,4 +61,5 @@ dispose() {
         this.disposable.remove(disposable, ...disposables);
+        return this;
     }
 }
 //# sourceMappingURL=abstractScheduler.js.map

dist/esm5/internal/priorityScheduler.js

@@ -85,2 +85,3 @@ import { createDisposable, createSerialDisposable, } from "@reactive-js/disposable";
         this.disposable.add(disposable, ...disposables);
+        return this;
     }
@@ -92,2 +93,3 @@ dispose() {
         this.disposable.remove(disposable, ...disposables);
+        return this;
     }
@@ -94,0 +96,0 @@ schedule(continuation, priority, delay = 0) {

dist/esm5/internal/synchronousScheduler.js

 import { AbstractVirtualTimeSchedulerResource, } from "./virtualTimeScheduler";
-import { throwIfDisposed, createDisposable, } from "@reactive-js/disposable";
+import { createDisposable } from "@reactive-js/disposable";
 const shouldYieldFalse = () => false;
 const shouldYieldTrue = () => true;
-const iteratorYield = {
-    done: false,
-    value: undefined,
-};
-const iteratorDone = {
-    done: true,
-    value: undefined,
-};
 class SynchronousSchedulerResource extends AbstractVirtualTimeSchedulerResource {
@@ -27,18 +19,16 @@ constructor() {
     }
-    next() {
-        throwIfDisposed(this);
-        this.shouldYield = shouldYieldTrue;
-        if (this.queue.length > 0) {
-            const next = this.queue.shift();
+    step() {
+        const next = this.queue.shift();
+        if (next !== undefined) {
             next();
         }
-        return this.queue.length > 0 ? iteratorYield : iteratorDone;
+        return this.queue.length > 0;
     }
+    next() {
+        this.shouldYield = shouldYieldTrue;
+        return super.next();
+    }
     run() {
-        throwIfDisposed(this);
         this.shouldYield = shouldYieldFalse;
-        for (let next = this.queue.shift(); next !== undefined; next = this.queue.shift()) {
-            next();
-        }
-        this.dispose();
+        super.run();
     }
@@ -45,0 +35,0 @@ }

dist/esm5/internal/virtualTimeScheduler.d.ts

@@ -1,14 +0,13 @@
-import { SchedulerLike, SchedulerResourceLike } from "@reactive-js/scheduler";
+import { SchedulerResourceLike } from "@reactive-js/scheduler";
 import { AbstractSchedulerResource } from "./abstractScheduler";
-export interface VirtualTimeSchedulerLike extends SchedulerLike, Iterator<void> {
+export interface VirtualTimeSchedulerResourceLike extends SchedulerResourceLike, Iterator<void> {
     run(): void;
 }
-export interface VirtualTimeSchedulerResourceLike extends SchedulerResourceLike, VirtualTimeSchedulerLike {
-}
 export declare abstract class AbstractVirtualTimeSchedulerResource extends AbstractSchedulerResource {
-    abstract step(): boolean;
+    protected abstract step(): boolean;
     next(): IteratorResult<void>;
     return(): IteratorResult<void>;
     throw(e?: any): IteratorResult<void>;
+    run(): void;
 }
 export declare const createVirtualTimeSchedulerResource: (maxMicroTaskTicks?: number) => VirtualTimeSchedulerResourceLike;

dist/esm5/internal/virtualTimeScheduler.js

@@ -29,2 +29,7 @@ import { createDisposable, throwIfDisposed, } from "@reactive-js/disposable";
     }
+    run() {
+        throwIfDisposed(this);
+        while (this.step()) { }
+        this.dispose();
+    }
 }
@@ -37,3 +42,3 @@ const comparator = (a, b) => {
 };
-class VirtualTimeSchedulerResourceImpl extends AbstractSchedulerResource {
+class VirtualTimeSchedulerResourceImpl extends AbstractVirtualTimeSchedulerResource {
     constructor(maxMicroTaskTicks) {
@@ -67,25 +72,17 @@ super();
     }
-    runNextTask() {
-        const { dueTime, callback, disposable, } = this.taskQueue.pop();
-        this._now = dueTime;
-        this.microTaskTicks = 0;
-        if (!disposable.isDisposed) {
-            callback();
-            disposable.dispose();
+    step() {
+        const task = this.taskQueue.pop();
+        if (task !== undefined) {
+            const { dueTime, callback, disposable } = task;
+            this._now = dueTime;
+            this.microTaskTicks = 0;
+            if (!disposable.isDisposed) {
+                callback();
+                disposable.dispose();
+            }
         }
+        return this.taskQueue.count > 0;
     }
-    next() {
-        throwIfDisposed(this);
-        this.runNextTask();
-        return this.taskQueue.count > 0 ? iteratorYield : iteratorDone;
-    }
-    run() {
-        throwIfDisposed(this);
-        while (this.taskQueue.count > 0) {
-            this.runNextTask();
-        }
-        this.dispose();
-    }
 }
 export const createVirtualTimeSchedulerResource = (maxMicroTaskTicks = Number.MAX_SAFE_INTEGER) => new VirtualTimeSchedulerResourceImpl(maxMicroTaskTicks);
 //# sourceMappingURL=virtualTimeScheduler.js.map

dist/types/index.d.ts

 export { createPrioritySchedulerResource, PrioritySchedulerLike, PrioritySchedulerResourceLike, } from "./internal/priorityScheduler";
-export { createVirtualTimeSchedulerResource, VirtualTimeSchedulerLike, VirtualTimeSchedulerResourceLike, } from "./internal/virtualTimeScheduler";
+export { createVirtualTimeSchedulerResource, VirtualTimeSchedulerResourceLike, } from "./internal/virtualTimeScheduler";
 export { createSynchronousSchedulerResource } from "./internal/synchronousScheduler";
@@ -4,0 +4,0 @@ export { createSchedulerWithPriority } from "./internal/schedulerWithPriority";

dist/types/internal/abstractScheduler.d.ts

@@ -18,6 +18,6 @@ import { DisposableLike, DisposableOrTeardown } from "@reactive-js/disposable";
     get isDisposed(): boolean;
-    add(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): void;
+    add(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): this;
     dispose(): void;
-    remove(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): void;
+    remove(disposable: DisposableOrTeardown, ...disposables: DisposableOrTeardown[]): this;
 }
 //# sourceMappingURL=abstractScheduler.d.ts.map

dist/types/internal/virtualTimeScheduler.d.ts

@@ -1,15 +0,14 @@
-import { SchedulerLike, SchedulerResourceLike } from "@reactive-js/scheduler";
+import { SchedulerResourceLike } from "@reactive-js/scheduler";
 import { AbstractSchedulerResource } from "./abstractScheduler";
-export interface VirtualTimeSchedulerLike extends SchedulerLike, Iterator<void> {
+export interface VirtualTimeSchedulerResourceLike extends SchedulerResourceLike, Iterator<void> {
     run(): void;
 }
-export interface VirtualTimeSchedulerResourceLike extends SchedulerResourceLike, VirtualTimeSchedulerLike {
-}
 export declare abstract class AbstractVirtualTimeSchedulerResource extends AbstractSchedulerResource {
-    abstract step(): boolean;
+    protected abstract step(): boolean;
     next(): IteratorResult<void>;
     return(): IteratorResult<void>;
     throw(e?: any): IteratorResult<void>;
+    run(): void;
 }
 export declare const createVirtualTimeSchedulerResource: (maxMicroTaskTicks?: number) => VirtualTimeSchedulerResourceLike;
 //# sourceMappingURL=virtualTimeScheduler.d.ts.map

docs/classes/abstractschedulerresource.md

@@ -11,4 +11,2 @@ [@reactive-js/schedulers](../README.md) › [AbstractSchedulerResource](abstractschedulerresource.md)
 
-  ↳ [AbstractVirtualTimeSchedulerResource](abstractvirtualtimeschedulerresource.md)
-
 ## Implements
@@ -15,0 +13,0 @@

docs/interfaces/virtualtimeschedulerresourcelike.md

@@ -15,4 +15,18 @@ [@reactive-js/schedulers](../README.md) › [VirtualTimeSchedulerResourceLike](virtualtimeschedulerresourcelike.md)
 
-  ↳ [VirtualTimeSchedulerLike](virtualtimeschedulerlike.md)
+* Iterator‹void›
 
   ↳ **VirtualTimeSchedulerResourceLike**
+
+## Index
+
+### Methods
+
+* [run](virtualtimeschedulerresourcelike.md#run)
+
+## Methods
+
+###  run
+
+▸ **run**(): *void*
+
+**Returns:** *void*

docs/README.md

@@ -11,3 +11,2 @@ [@reactive-js/schedulers](README.md)
 * [AbstractSchedulerResource](classes/abstractschedulerresource.md)
-* [AbstractVirtualTimeSchedulerResource](classes/abstractvirtualtimeschedulerresource.md)
 
@@ -18,3 +17,2 @@ ### Interfaces
 * [PrioritySchedulerResourceLike](interfaces/priorityschedulerresourcelike.md)
-* [VirtualTimeSchedulerLike](interfaces/virtualtimeschedulerlike.md)
 * [VirtualTimeSchedulerResourceLike](interfaces/virtualtimeschedulerresourcelike.md)
@@ -21,0 +19,0 @@

package.json

 {
   "name": "@reactive-js/schedulers",
-  "version": "0.0.11",
+  "version": "0.0.12",
   "main": "dist/cjs/index.js",
@@ -41,4 +41,4 @@ "module": "dist/esm5/index.js",
   "dependencies": {
-    "@reactive-js/disposable": "^0.0.11",
-    "@reactive-js/scheduler": "^0.0.11"
+    "@reactive-js/disposable": "^0.0.12",
+    "@reactive-js/scheduler": "^0.0.12"
   },
@@ -70,3 +70,3 @@ "devDependencies": {
   },
-  "gitHead": "894e4863ea037c317967555ebc27ab66167cfc59"
+  "gitHead": "66ee9bfeeb79e01c9770dc09829bedf292674ff0"
 }

src/index.ts

@@ -9,3 +9,2 @@ export {
   createVirtualTimeSchedulerResource,
-  VirtualTimeSchedulerLike,
   VirtualTimeSchedulerResourceLike,
@@ -12,0 +11,0 @@ } from "./internal/virtualTimeScheduler";

src/internal/abstractScheduler.ts

@@ -91,2 +91,3 @@ import {
     this.disposable.add(disposable, ...disposables);
+    return this;
   }
@@ -105,3 +106,4 @@
     this.disposable.remove(disposable, ...disposables);
+    return this;
   }
 }

src/internal/priorityScheduler.ts

@@ -152,2 +152,3 @@ import {
     this.disposable.add(disposable, ...disposables);
+    return this;
   }
@@ -164,2 +165,3 @@
     this.disposable.remove(disposable, ...disposables);
+    return this;
   }
@@ -166,0 +168,0 @@

src/internal/synchronousScheduler.ts

@@ -5,7 +5,3 @@ import {
 } from "./virtualTimeScheduler";
-import {
-  DisposableLike,
-  throwIfDisposed,
-  createDisposable,
-} from "@reactive-js/disposable";
+import { DisposableLike, createDisposable } from "@reactive-js/disposable";
 
@@ -16,12 +12,2 @@ // Intentionally defined as a module function for perf reasons.
 
-const iteratorYield = {
-  done: false,
-  value: undefined,
-};
-
-const iteratorDone = {
-  done: true,
-  value: undefined,
-};
-
 // @ts-ignore override shouldYield for perf
@@ -46,27 +32,18 @@ class SynchronousSchedulerResource extends AbstractVirtualTimeSchedulerResource
 
-  next(): IteratorResult<void> {
-    throwIfDisposed(this);
-
-    this.shouldYield = shouldYieldTrue;
-    if (this.queue.length > 0) {
-      const next = this.queue.shift() as () => void;
+  protected step(): boolean {
+    const next = this.queue.shift();
+    if (next !== undefined) {
       next();
     }
+    return this.queue.length > 0;
+  }
 
-    return this.queue.length > 0 ? iteratorYield : iteratorDone;
+  next(): IteratorResult<void> {
+    this.shouldYield = shouldYieldTrue;
+    return super.next();
   }
 
   run() {
-    throwIfDisposed(this);
     this.shouldYield = shouldYieldFalse;
-
-    for (
-      let next = this.queue.shift();
-      next !== undefined;
-      next = this.queue.shift()
-    ) {
-      next();
-    }
-
-    this.dispose();
+    super.run();
   }
@@ -73,0 +50,0 @@ }

src/internal/virtualTimeScheduler.ts

@@ -6,3 +6,3 @@ import {
 } from "@reactive-js/disposable";
-import { SchedulerLike, SchedulerResourceLike } from "@reactive-js/scheduler";
+import { SchedulerResourceLike } from "@reactive-js/scheduler";
 import { createPriorityQueue, PriorityQueueLike } from "./priorityQueue";
@@ -12,4 +12,4 @@ import { AbstractSchedulerResource } from "./abstractScheduler";
 /** @noInheritDoc */
-export interface VirtualTimeSchedulerLike
-  extends SchedulerLike,
+export interface VirtualTimeSchedulerResourceLike
+  extends SchedulerResourceLike,
     Iterator<void> {
@@ -19,7 +19,2 @@ run(): void;
 
-/** @noInheritDoc */
-export interface VirtualTimeSchedulerResourceLike
-  extends SchedulerResourceLike,
-    VirtualTimeSchedulerLike {}
-
 const iteratorYield = {
@@ -35,4 +30,5 @@ done: false,
 
+/** @ignore */
 export abstract class AbstractVirtualTimeSchedulerResource extends AbstractSchedulerResource {
-  abstract step(): boolean;
+  protected abstract step(): boolean;
 
@@ -58,2 +54,8 @@ next(): IteratorResult<void> {
   }
+
+  run() {
+    throwIfDisposed(this);
+    while (this.step()) {}
+    this.dispose();
+  }
 }
@@ -75,3 +77,4 @@
 
-class VirtualTimeSchedulerResourceImpl extends AbstractSchedulerResource
+class VirtualTimeSchedulerResourceImpl
+  extends AbstractVirtualTimeSchedulerResource
   implements VirtualTimeSchedulerResourceLike {
@@ -114,33 +117,19 @@ private _now = 0;
 
-  private runNextTask() {
-    const {
-      dueTime,
-      callback,
-      disposable,
-    } = this.taskQueue.pop() as VirtualTask;
+  protected step(): boolean {
+    const task = this.taskQueue.pop();
 
-    this._now = dueTime;
-    this.microTaskTicks = 0;
+    if (task !== undefined) {
+      const { dueTime, callback, disposable } = task;
 
-    if (!disposable.isDisposed) {
-      callback();
-      disposable.dispose();
+      this._now = dueTime;
+      this.microTaskTicks = 0;
+
+      if (!disposable.isDisposed) {
+        callback();
+        disposable.dispose();
+      }
     }
-  }
 
-  next(): IteratorResult<void> {
-    throwIfDisposed(this);
-
-    this.runNextTask();
-
-    return this.taskQueue.count > 0 ? iteratorYield : iteratorDone;
+    return this.taskQueue.count > 0;
   }
-
-  run() {
-    throwIfDisposed(this);
-    while (this.taskQueue.count > 0) {
-      this.runNextTask();
-    }
-    this.dispose();
-  }
 }
@@ -147,0 +136,0 @@

No alert changes

Worsened metrics

Total package byte prevSize

439801

decreased by-1.19%

Number of package files

81

decreased by-2.41%

Lines of code

1646

decreased by-2.66%

Dependency changes

• + Added@reactive-js/disposable@0.0.12(transitive)

• + Added@reactive-js/scheduler@0.0.12(transitive)

• - Removed@reactive-js/disposable@0.0.11(transitive)

• - Removed@reactive-js/scheduler@0.0.11(transitive)

• Updated@reactive-js/disposable@^0.0.12

• Updated@reactive-js/scheduler@^0.0.12