New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@reactive-js/schedulers

Package Overview
Dependencies
Maintainers
1
Versions
31
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@reactive-js/schedulers - npm Package Compare versions

Comparing version 0.0.24 to 0.0.25

7

dist/cjs/internal/priorityScheduler.js

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc