@reactive-js/schedulers
Advanced tools
Comparing version 0.0.24 to 0.0.25
@@ -18,5 +18,6 @@ "use strict"; | ||
this.queue = priorityQueue_1.createPriorityQueue(comparator); | ||
this.taskIDCounter = 0; | ||
this.add = disposable_1.disposableMixin.add; | ||
this.currentTask = undefined; | ||
this.currentShouldYield = undefined; | ||
this.dispose = disposable_1.disposableMixin.dispose; | ||
this.shouldYield = () => { | ||
@@ -34,5 +35,3 @@ const currentTaskIsDisposed = this.currentTask !== undefined && this.currentTask.disposable.isDisposed; | ||
}; | ||
this.add = disposable_1.disposableMixin.add; | ||
this.dispose = disposable_1.disposableMixin.dispose; | ||
this.remove = disposable_1.disposableMixin.remove; | ||
this.taskIDCounter = 0; | ||
} | ||
@@ -39,0 +38,0 @@ get isDisposed() { |
import { DisposableLike } from "@reactive-js/disposable"; | ||
import { SchedulerContinuationLike } from "@reactive-js/scheduler"; | ||
export interface SchedulerHost { | ||
readonly now: number; | ||
import { SchedulerContinuationLike, SchedulerLike } from "@reactive-js/scheduler"; | ||
export interface SchedulerHost extends SchedulerLike { | ||
readonly shouldYield: (() => boolean) | undefined; | ||
@@ -6,0 +5,0 @@ scheduleCallback(callback: () => void, delay?: number): DisposableLike; |
@@ -23,8 +23,9 @@ "use strict"; | ||
this.maxMicroTaskTicks = maxMicroTaskTicks; | ||
this.add = disposable_1.disposableMixin.add; | ||
this.continuationResult = { continuation: this }; | ||
this.disposable = disposable_1.createDisposable(); | ||
this.dispose = disposable_1.disposableMixin.dispose; | ||
this.microTaskTicks = 0; | ||
this.now = 0; | ||
this.taskIDCount = 0; | ||
this.taskQueue = priorityQueue_1.createPriorityQueue(comparator); | ||
this.schedule = schedulerMixin_1.schedulerMixin.schedule; | ||
this.shouldYield = () => { | ||
@@ -36,6 +37,4 @@ const runShouldYield = this.runShouldYield; | ||
}; | ||
this.add = disposable_1.disposableMixin.add; | ||
this.dispose = disposable_1.disposableMixin.dispose; | ||
this.remove = disposable_1.disposableMixin.remove; | ||
this.schedule = schedulerMixin_1.schedulerMixin.schedule; | ||
this.taskIDCount = 0; | ||
this.taskQueue = priorityQueue_1.createPriorityQueue(comparator); | ||
} | ||
@@ -42,0 +41,0 @@ get isDisposed() { |
@@ -16,5 +16,6 @@ import { createDisposable, createSerialDisposable, disposableMixin, } from "@reactive-js/disposable"; | ||
this.queue = createPriorityQueue(comparator); | ||
this.taskIDCounter = 0; | ||
this.add = disposableMixin.add; | ||
this.currentTask = undefined; | ||
this.currentShouldYield = undefined; | ||
this.dispose = disposableMixin.dispose; | ||
this.shouldYield = () => { | ||
@@ -32,5 +33,3 @@ const currentTaskIsDisposed = this.currentTask !== undefined && this.currentTask.disposable.isDisposed; | ||
}; | ||
this.add = disposableMixin.add; | ||
this.dispose = disposableMixin.dispose; | ||
this.remove = disposableMixin.remove; | ||
this.taskIDCounter = 0; | ||
} | ||
@@ -37,0 +36,0 @@ get isDisposed() { |
import { DisposableLike } from "@reactive-js/disposable"; | ||
import { SchedulerContinuationLike } from "@reactive-js/scheduler"; | ||
export interface SchedulerHost { | ||
readonly now: number; | ||
import { SchedulerContinuationLike, SchedulerLike } from "@reactive-js/scheduler"; | ||
export interface SchedulerHost extends SchedulerLike { | ||
readonly shouldYield: (() => boolean) | undefined; | ||
@@ -6,0 +5,0 @@ scheduleCallback(callback: () => void, delay?: number): DisposableLike; |
@@ -21,8 +21,9 @@ import { createDisposable, throwIfDisposed, disposableMixin, } from "@reactive-js/disposable"; | ||
this.maxMicroTaskTicks = maxMicroTaskTicks; | ||
this.add = disposableMixin.add; | ||
this.continuationResult = { continuation: this }; | ||
this.disposable = createDisposable(); | ||
this.dispose = disposableMixin.dispose; | ||
this.microTaskTicks = 0; | ||
this.now = 0; | ||
this.taskIDCount = 0; | ||
this.taskQueue = createPriorityQueue(comparator); | ||
this.schedule = schedulerMixin.schedule; | ||
this.shouldYield = () => { | ||
@@ -34,6 +35,4 @@ const runShouldYield = this.runShouldYield; | ||
}; | ||
this.add = disposableMixin.add; | ||
this.dispose = disposableMixin.dispose; | ||
this.remove = disposableMixin.remove; | ||
this.schedule = schedulerMixin.schedule; | ||
this.taskIDCount = 0; | ||
this.taskQueue = createPriorityQueue(comparator); | ||
} | ||
@@ -40,0 +39,0 @@ get isDisposed() { |
import { DisposableLike } from "@reactive-js/disposable"; | ||
import { SchedulerContinuationLike } from "@reactive-js/scheduler"; | ||
export interface SchedulerHost { | ||
readonly now: number; | ||
import { SchedulerContinuationLike, SchedulerLike } from "@reactive-js/scheduler"; | ||
export interface SchedulerHost extends SchedulerLike { | ||
readonly shouldYield: (() => boolean) | undefined; | ||
@@ -6,0 +5,0 @@ scheduleCallback(callback: () => void, delay?: number): DisposableLike; |
@@ -7,4 +7,6 @@ [@reactive-js/schedulers](../README.md) › [SchedulerHost](schedulerhost.md) | ||
* **SchedulerHost** | ||
* SchedulerLike | ||
↳ **SchedulerHost** | ||
## Index | ||
@@ -19,2 +21,3 @@ | ||
* [schedule](schedulerhost.md#schedule) | ||
* [scheduleCallback](schedulerhost.md#schedulecallback) | ||
@@ -28,2 +31,4 @@ | ||
*Inherited from void* | ||
___ | ||
@@ -37,2 +42,19 @@ | ||
### schedule | ||
▸ **schedule**(`continuation`: SchedulerContinuationLike, `delay?`: undefined | number): *DisposableLike* | ||
*Inherited from void* | ||
**Parameters:** | ||
Name | Type | | ||
------ | ------ | | ||
`continuation` | SchedulerContinuationLike | | ||
`delay?` | undefined | number | | ||
**Returns:** *DisposableLike* | ||
___ | ||
### scheduleCallback | ||
@@ -39,0 +61,0 @@ |
{ | ||
"name": "@reactive-js/schedulers", | ||
"version": "0.0.24", | ||
"version": "0.0.25", | ||
"main": "dist/cjs/index.js", | ||
@@ -41,4 +41,4 @@ "module": "dist/esm5/index.js", | ||
"dependencies": { | ||
"@reactive-js/disposable": "^0.0.24", | ||
"@reactive-js/scheduler": "^0.0.24" | ||
"@reactive-js/disposable": "^0.0.25", | ||
"@reactive-js/scheduler": "^0.0.25" | ||
}, | ||
@@ -70,3 +70,3 @@ "devDependencies": { | ||
}, | ||
"gitHead": "19ba0c0276afd9ca23aae5497c04c1f63d2d72a4" | ||
"gitHead": "c23221b85a7fc7f4252783af164069c6397f41de" | ||
} |
@@ -55,5 +55,7 @@ import { | ||
> = createPriorityQueue(comparator); | ||
private taskIDCounter = 0; | ||
readonly add = disposableMixin.add; | ||
private currentTask: ScheduledTaskLike | undefined = undefined; | ||
private currentShouldYield: (() => boolean) | undefined = undefined; | ||
readonly dispose = disposableMixin.dispose; | ||
private shouldYield = () => { | ||
@@ -79,9 +81,4 @@ const currentTaskIsDisposed = | ||
}; | ||
private taskIDCounter = 0; | ||
/** @ignore */ | ||
add = disposableMixin.add; | ||
/** @ignore */ | ||
dispose = disposableMixin.dispose; | ||
/** @ignore */ | ||
remove = disposableMixin.remove; | ||
constructor(private readonly hostScheduler: SchedulerLike) {} | ||
@@ -88,0 +85,0 @@ |
@@ -6,6 +6,8 @@ import { | ||
} from "@reactive-js/disposable"; | ||
import { SchedulerContinuationLike } from "@reactive-js/scheduler"; | ||
import { | ||
SchedulerContinuationLike, | ||
SchedulerLike, | ||
} from "@reactive-js/scheduler"; | ||
export interface SchedulerHost { | ||
readonly now: number; | ||
export interface SchedulerHost extends SchedulerLike { | ||
readonly shouldYield: (() => boolean) | undefined; | ||
@@ -12,0 +14,0 @@ |
@@ -47,13 +47,11 @@ import { | ||
implements VirtualTimeSchedulerResourceLike { | ||
readonly add = disposableMixin.add; | ||
private readonly continuationResult = { continuation: this }; | ||
readonly disposable: DisposableLike = createDisposable(); | ||
readonly dispose = disposableMixin.dispose; | ||
private microTaskTicks = 0; | ||
now = 0; | ||
private runShouldYield?: () => boolean; | ||
private taskIDCount = 0; | ||
private readonly taskQueue: PriorityQueueLike< | ||
VirtualTask | ||
> = createPriorityQueue(comparator); | ||
protected shouldYield: (() => boolean) | undefined = () => { | ||
readonly schedule = schedulerMixin.schedule; | ||
shouldYield: (() => boolean) | undefined = () => { | ||
const runShouldYield = this.runShouldYield; | ||
@@ -66,7 +64,7 @@ this.microTaskTicks++; | ||
}; | ||
private taskIDCount = 0; | ||
private readonly taskQueue: PriorityQueueLike< | ||
VirtualTask | ||
> = createPriorityQueue(comparator); | ||
add = disposableMixin.add; | ||
dispose = disposableMixin.dispose; | ||
remove = disposableMixin.remove; | ||
schedule = schedulerMixin.schedule; | ||
constructor(private readonly maxMicroTaskTicks: number) {} | ||
@@ -73,0 +71,0 @@ |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
419684
1378
+ Added@reactive-js/disposable@0.0.25(transitive)
+ Added@reactive-js/scheduler@0.0.25(transitive)
- Removed@reactive-js/disposable@0.0.24(transitive)
- Removed@reactive-js/scheduler@0.0.24(transitive)