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

client-run-queue

Package Overview
Dependencies
Maintainers
1
Versions
34
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

client-run-queue - npm Package Compare versions

Comparing version 1.0.0 to 1.1.0

SECURITY.md

2

docs/assets/search.js

@@ -1,1 +0,1 @@

window.searchData = JSON.parse("{\"kinds\":{\"32\":\"Variable\",\"64\":\"Function\",\"128\":\"Class\",\"256\":\"Interface\",\"512\":\"Constructor\",\"1024\":\"Property\",\"2048\":\"Method\",\"4194304\":\"Type alias\"},\"rows\":[{\"id\":0,\"kind\":64,\"name\":\"runAfterInteractions\",\"url\":\"modules.html#runAfterInteractions\",\"classes\":\"tsd-kind-function\"},{\"id\":1,\"kind\":64,\"name\":\"resetRunAfterInteractions\",\"url\":\"modules.html#resetRunAfterInteractions\",\"classes\":\"tsd-kind-function\"},{\"id\":2,\"kind\":64,\"name\":\"setRunAfterInteractions\",\"url\":\"modules.html#setRunAfterInteractions\",\"classes\":\"tsd-kind-function\"},{\"id\":3,\"kind\":256,\"name\":\"StatsHandler\",\"url\":\"interfaces/StatsHandler.html\",\"classes\":\"tsd-kind-interface\"},{\"id\":4,\"kind\":2048,\"name\":\"trackRunQueueDidCancelAllCancelableEntries\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidCancelAllCancelableEntries\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":5,\"kind\":2048,\"name\":\"trackRunQueueDidCancelEntry\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidCancelEntry\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":6,\"kind\":2048,\"name\":\"trackRunQueueDidCompleteIteration\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidCompleteIteration\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":7,\"kind\":2048,\"name\":\"trackRunQueueDidProcessEntry\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidProcessEntry\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":8,\"kind\":2048,\"name\":\"trackRunQueueDidSchedule\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidSchedule\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":9,\"kind\":64,\"name\":\"getStatsHandler\",\"url\":\"modules.html#getStatsHandler\",\"classes\":\"tsd-kind-function\"},{\"id\":10,\"kind\":64,\"name\":\"resetStatsHandler\",\"url\":\"modules.html#resetStatsHandler\",\"classes\":\"tsd-kind-function\"},{\"id\":11,\"kind\":64,\"name\":\"setStatsHandler\",\"url\":\"modules.html#setStatsHandler\",\"classes\":\"tsd-kind-function\"},{\"id\":12,\"kind\":32,\"name\":\"DEFAULT_PRIORITY\",\"url\":\"modules.html#DEFAULT_PRIORITY\",\"classes\":\"tsd-kind-variable\"},{\"id\":13,\"kind\":32,\"name\":\"UI_PRIORITY\",\"url\":\"modules.html#UI_PRIORITY\",\"classes\":\"tsd-kind-variable\"},{\"id\":14,\"kind\":32,\"name\":\"CANCELED\",\"url\":\"modules.html#CANCELED\",\"classes\":\"tsd-kind-variable\"},{\"id\":15,\"kind\":128,\"name\":\"RunQueue\",\"url\":\"classes/RunQueue.html\",\"classes\":\"tsd-kind-class\"},{\"id\":16,\"kind\":512,\"name\":\"constructor\",\"url\":\"classes/RunQueue.html#constructor\",\"classes\":\"tsd-kind-constructor tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":17,\"kind\":1024,\"name\":\"continuousWorkMaxEntries\",\"url\":\"classes/RunQueue.html#continuousWorkMaxEntries\",\"classes\":\"tsd-kind-property tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":18,\"kind\":1024,\"name\":\"continuousWorkTimeLimitMSec\",\"url\":\"classes/RunQueue.html#continuousWorkTimeLimitMSec\",\"classes\":\"tsd-kind-property tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":19,\"kind\":1024,\"name\":\"maxParallel\",\"url\":\"classes/RunQueue.html#maxParallel\",\"classes\":\"tsd-kind-property tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":20,\"kind\":1024,\"name\":\"id\",\"url\":\"classes/RunQueue.html#id\",\"classes\":\"tsd-kind-property tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":21,\"kind\":2048,\"name\":\"cancelAll\",\"url\":\"classes/RunQueue.html#cancelAll\",\"classes\":\"tsd-kind-method tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":22,\"kind\":2048,\"name\":\"getQueueLength\",\"url\":\"classes/RunQueue.html#getQueueLength\",\"classes\":\"tsd-kind-method tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":23,\"kind\":2048,\"name\":\"schedule\",\"url\":\"classes/RunQueue.html#schedule\",\"classes\":\"tsd-kind-method tsd-parent-kind-class tsd-has-type-parameter\",\"parent\":\"RunQueue\"},{\"id\":24,\"kind\":4194304,\"name\":\"RunQueueEntryResult\",\"url\":\"modules.html#RunQueueEntryResult\",\"classes\":\"tsd-kind-type-alias tsd-has-type-parameter\"},{\"id\":25,\"kind\":256,\"name\":\"RunQueueEntry\",\"url\":\"interfaces/RunQueueEntry.html\",\"classes\":\"tsd-kind-interface tsd-has-type-parameter\"},{\"id\":26,\"kind\":1024,\"name\":\"promise\",\"url\":\"interfaces/RunQueueEntry.html#promise\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":27,\"kind\":2048,\"name\":\"cancel\",\"url\":\"interfaces/RunQueueEntry.html#cancel\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":28,\"kind\":2048,\"name\":\"wasCanceled\",\"url\":\"interfaces/RunQueueEntry.html#wasCanceled\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":29,\"kind\":2048,\"name\":\"wasCompleted\",\"url\":\"interfaces/RunQueueEntry.html#wasCompleted\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":30,\"kind\":2048,\"name\":\"wasStarted\",\"url\":\"interfaces/RunQueueEntry.html#wasStarted\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":31,\"kind\":256,\"name\":\"RunQueueOptions\",\"url\":\"interfaces/RunQueueOptions.html\",\"classes\":\"tsd-kind-interface\"},{\"id\":32,\"kind\":1024,\"name\":\"continuousWorkMaxEntries\",\"url\":\"interfaces/RunQueueOptions.html#continuousWorkMaxEntries\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueOptions\"},{\"id\":33,\"kind\":1024,\"name\":\"continuousWorkTimeLimitMSec\",\"url\":\"interfaces/RunQueueOptions.html#continuousWorkTimeLimitMSec\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueOptions\"},{\"id\":34,\"kind\":1024,\"name\":\"maxParallel\",\"url\":\"interfaces/RunQueueOptions.html#maxParallel\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueOptions\"},{\"id\":35,\"kind\":256,\"name\":\"RunQueueScheduleOptions\",\"url\":\"interfaces/RunQueueScheduleOptions.html\",\"classes\":\"tsd-kind-interface\"},{\"id\":36,\"kind\":1024,\"name\":\"neverCancel\",\"url\":\"interfaces/RunQueueScheduleOptions.html#neverCancel\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueScheduleOptions\"}],\"index\":{\"version\":\"2.3.9\",\"fields\":[\"name\",\"parent\"],\"fieldVectors\":[[\"name/0\",[0,32.321]],[\"parent/0\",[]],[\"name/1\",[1,32.321]],[\"parent/1\",[]],[\"name/2\",[2,32.321]],[\"parent/2\",[]],[\"name/3\",[3,17.658]],[\"parent/3\",[]],[\"name/4\",[4,32.321]],[\"parent/4\",[3,1.381]],[\"name/5\",[5,32.321]],[\"parent/5\",[3,1.381]],[\"name/6\",[6,32.321]],[\"parent/6\",[3,1.381]],[\"name/7\",[7,32.321]],[\"parent/7\",[3,1.381]],[\"name/8\",[8,32.321]],[\"parent/8\",[3,1.381]],[\"name/9\",[9,32.321]],[\"parent/9\",[]],[\"name/10\",[10,32.321]],[\"parent/10\",[]],[\"name/11\",[11,32.321]],[\"parent/11\",[]],[\"name/12\",[12,32.321]],[\"parent/12\",[]],[\"name/13\",[13,32.321]],[\"parent/13\",[]],[\"name/14\",[14,32.321]],[\"parent/14\",[]],[\"name/15\",[15,13.863]],[\"parent/15\",[]],[\"name/16\",[16,32.321]],[\"parent/16\",[15,1.084]],[\"name/17\",[17,27.213]],[\"parent/17\",[15,1.084]],[\"name/18\",[18,27.213]],[\"parent/18\",[15,1.084]],[\"name/19\",[19,27.213]],[\"parent/19\",[15,1.084]],[\"name/20\",[20,32.321]],[\"parent/20\",[15,1.084]],[\"name/21\",[21,32.321]],[\"parent/21\",[15,1.084]],[\"name/22\",[22,32.321]],[\"parent/22\",[15,1.084]],[\"name/23\",[23,32.321]],[\"parent/23\",[15,1.084]],[\"name/24\",[24,32.321]],[\"parent/24\",[]],[\"name/25\",[25,17.658]],[\"parent/25\",[]],[\"name/26\",[26,32.321]],[\"parent/26\",[25,1.381]],[\"name/27\",[27,32.321]],[\"parent/27\",[25,1.381]],[\"name/28\",[28,32.321]],[\"parent/28\",[25,1.381]],[\"name/29\",[29,32.321]],[\"parent/29\",[25,1.381]],[\"name/30\",[30,32.321]],[\"parent/30\",[25,1.381]],[\"name/31\",[31,21.335]],[\"parent/31\",[]],[\"name/32\",[17,27.213]],[\"parent/32\",[31,1.668]],[\"name/33\",[18,27.213]],[\"parent/33\",[31,1.668]],[\"name/34\",[19,27.213]],[\"parent/34\",[31,1.668]],[\"name/35\",[32,27.213]],[\"parent/35\",[]],[\"name/36\",[33,32.321]],[\"parent/36\",[32,2.128]]],\"invertedIndex\":[[\"cancel\",{\"_index\":27,\"name\":{\"27\":{}},\"parent\":{}}],[\"cancelall\",{\"_index\":21,\"name\":{\"21\":{}},\"parent\":{}}],[\"canceled\",{\"_index\":14,\"name\":{\"14\":{}},\"parent\":{}}],[\"constructor\",{\"_index\":16,\"name\":{\"16\":{}},\"parent\":{}}],[\"continuousworkmaxentries\",{\"_index\":17,\"name\":{\"17\":{},\"32\":{}},\"parent\":{}}],[\"continuousworktimelimitmsec\",{\"_index\":18,\"name\":{\"18\":{},\"33\":{}},\"parent\":{}}],[\"default_priority\",{\"_index\":12,\"name\":{\"12\":{}},\"parent\":{}}],[\"getqueuelength\",{\"_index\":22,\"name\":{\"22\":{}},\"parent\":{}}],[\"getstatshandler\",{\"_index\":9,\"name\":{\"9\":{}},\"parent\":{}}],[\"id\",{\"_index\":20,\"name\":{\"20\":{}},\"parent\":{}}],[\"maxparallel\",{\"_index\":19,\"name\":{\"19\":{},\"34\":{}},\"parent\":{}}],[\"nevercancel\",{\"_index\":33,\"name\":{\"36\":{}},\"parent\":{}}],[\"promise\",{\"_index\":26,\"name\":{\"26\":{}},\"parent\":{}}],[\"resetrunafterinteractions\",{\"_index\":1,\"name\":{\"1\":{}},\"parent\":{}}],[\"resetstatshandler\",{\"_index\":10,\"name\":{\"10\":{}},\"parent\":{}}],[\"runafterinteractions\",{\"_index\":0,\"name\":{\"0\":{}},\"parent\":{}}],[\"runqueue\",{\"_index\":15,\"name\":{\"15\":{}},\"parent\":{\"16\":{},\"17\":{},\"18\":{},\"19\":{},\"20\":{},\"21\":{},\"22\":{},\"23\":{}}}],[\"runqueueentry\",{\"_index\":25,\"name\":{\"25\":{}},\"parent\":{\"26\":{},\"27\":{},\"28\":{},\"29\":{},\"30\":{}}}],[\"runqueueentryresult\",{\"_index\":24,\"name\":{\"24\":{}},\"parent\":{}}],[\"runqueueoptions\",{\"_index\":31,\"name\":{\"31\":{}},\"parent\":{\"32\":{},\"33\":{},\"34\":{}}}],[\"runqueuescheduleoptions\",{\"_index\":32,\"name\":{\"35\":{}},\"parent\":{\"36\":{}}}],[\"schedule\",{\"_index\":23,\"name\":{\"23\":{}},\"parent\":{}}],[\"setrunafterinteractions\",{\"_index\":2,\"name\":{\"2\":{}},\"parent\":{}}],[\"setstatshandler\",{\"_index\":11,\"name\":{\"11\":{}},\"parent\":{}}],[\"statshandler\",{\"_index\":3,\"name\":{\"3\":{}},\"parent\":{\"4\":{},\"5\":{},\"6\":{},\"7\":{},\"8\":{}}}],[\"trackrunqueuedidcancelallcancelableentries\",{\"_index\":4,\"name\":{\"4\":{}},\"parent\":{}}],[\"trackrunqueuedidcancelentry\",{\"_index\":5,\"name\":{\"5\":{}},\"parent\":{}}],[\"trackrunqueuedidcompleteiteration\",{\"_index\":6,\"name\":{\"6\":{}},\"parent\":{}}],[\"trackrunqueuedidprocessentry\",{\"_index\":7,\"name\":{\"7\":{}},\"parent\":{}}],[\"trackrunqueuedidschedule\",{\"_index\":8,\"name\":{\"8\":{}},\"parent\":{}}],[\"ui_priority\",{\"_index\":13,\"name\":{\"13\":{}},\"parent\":{}}],[\"wascanceled\",{\"_index\":28,\"name\":{\"28\":{}},\"parent\":{}}],[\"wascompleted\",{\"_index\":29,\"name\":{\"29\":{}},\"parent\":{}}],[\"wasstarted\",{\"_index\":30,\"name\":{\"30\":{}},\"parent\":{}}]],\"pipeline\":[]}}");
window.searchData = JSON.parse("{\"kinds\":{\"32\":\"Variable\",\"64\":\"Function\",\"128\":\"Class\",\"256\":\"Interface\",\"512\":\"Constructor\",\"1024\":\"Property\",\"2048\":\"Method\",\"4194304\":\"Type alias\"},\"rows\":[{\"id\":0,\"kind\":64,\"name\":\"runAfterInteractions\",\"url\":\"modules.html#runAfterInteractions\",\"classes\":\"tsd-kind-function\"},{\"id\":1,\"kind\":64,\"name\":\"resetRunAfterInteractions\",\"url\":\"modules.html#resetRunAfterInteractions\",\"classes\":\"tsd-kind-function\"},{\"id\":2,\"kind\":64,\"name\":\"setRunAfterInteractions\",\"url\":\"modules.html#setRunAfterInteractions\",\"classes\":\"tsd-kind-function\"},{\"id\":3,\"kind\":256,\"name\":\"StatsHandler\",\"url\":\"interfaces/StatsHandler.html\",\"classes\":\"tsd-kind-interface\"},{\"id\":4,\"kind\":2048,\"name\":\"trackRunQueueDidCancelAllCancelableEntries\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidCancelAllCancelableEntries\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":5,\"kind\":2048,\"name\":\"trackRunQueueDidCancelEntry\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidCancelEntry\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":6,\"kind\":2048,\"name\":\"trackRunQueueDidCompleteIteration\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidCompleteIteration\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":7,\"kind\":2048,\"name\":\"trackRunQueueDidProcessEntry\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidProcessEntry\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":8,\"kind\":2048,\"name\":\"trackRunQueueDidSchedule\",\"url\":\"interfaces/StatsHandler.html#trackRunQueueDidSchedule\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"StatsHandler\"},{\"id\":9,\"kind\":64,\"name\":\"getStatsHandler\",\"url\":\"modules.html#getStatsHandler\",\"classes\":\"tsd-kind-function\"},{\"id\":10,\"kind\":64,\"name\":\"resetStatsHandler\",\"url\":\"modules.html#resetStatsHandler\",\"classes\":\"tsd-kind-function\"},{\"id\":11,\"kind\":64,\"name\":\"setStatsHandler\",\"url\":\"modules.html#setStatsHandler\",\"classes\":\"tsd-kind-function\"},{\"id\":12,\"kind\":32,\"name\":\"DEFAULT_PRIORITY\",\"url\":\"modules.html#DEFAULT_PRIORITY\",\"classes\":\"tsd-kind-variable\"},{\"id\":13,\"kind\":32,\"name\":\"UI_PRIORITY\",\"url\":\"modules.html#UI_PRIORITY\",\"classes\":\"tsd-kind-variable\"},{\"id\":14,\"kind\":32,\"name\":\"CANCELED\",\"url\":\"modules.html#CANCELED\",\"classes\":\"tsd-kind-variable\"},{\"id\":15,\"kind\":128,\"name\":\"RunQueue\",\"url\":\"classes/RunQueue.html\",\"classes\":\"tsd-kind-class\"},{\"id\":16,\"kind\":512,\"name\":\"constructor\",\"url\":\"classes/RunQueue.html#constructor\",\"classes\":\"tsd-kind-constructor tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":17,\"kind\":1024,\"name\":\"continuousWorkMaxEntries\",\"url\":\"classes/RunQueue.html#continuousWorkMaxEntries\",\"classes\":\"tsd-kind-property tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":18,\"kind\":1024,\"name\":\"continuousWorkTimeLimitMSec\",\"url\":\"classes/RunQueue.html#continuousWorkTimeLimitMSec\",\"classes\":\"tsd-kind-property tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":19,\"kind\":1024,\"name\":\"maxParallel\",\"url\":\"classes/RunQueue.html#maxParallel\",\"classes\":\"tsd-kind-property tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":20,\"kind\":1024,\"name\":\"id\",\"url\":\"classes/RunQueue.html#id\",\"classes\":\"tsd-kind-property tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":21,\"kind\":2048,\"name\":\"cancelAll\",\"url\":\"classes/RunQueue.html#cancelAll\",\"classes\":\"tsd-kind-method tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":22,\"kind\":2048,\"name\":\"getQueueLength\",\"url\":\"classes/RunQueue.html#getQueueLength\",\"classes\":\"tsd-kind-method tsd-parent-kind-class\",\"parent\":\"RunQueue\"},{\"id\":23,\"kind\":2048,\"name\":\"schedule\",\"url\":\"classes/RunQueue.html#schedule\",\"classes\":\"tsd-kind-method tsd-parent-kind-class tsd-has-type-parameter\",\"parent\":\"RunQueue\"},{\"id\":24,\"kind\":4194304,\"name\":\"RunQueueEntryResult\",\"url\":\"modules.html#RunQueueEntryResult\",\"classes\":\"tsd-kind-type-alias tsd-has-type-parameter\"},{\"id\":25,\"kind\":256,\"name\":\"RunQueueEntry\",\"url\":\"interfaces/RunQueueEntry.html\",\"classes\":\"tsd-kind-interface tsd-has-type-parameter\"},{\"id\":26,\"kind\":1024,\"name\":\"promise\",\"url\":\"interfaces/RunQueueEntry.html#promise\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":27,\"kind\":2048,\"name\":\"cancel\",\"url\":\"interfaces/RunQueueEntry.html#cancel\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":28,\"kind\":2048,\"name\":\"wasCanceled\",\"url\":\"interfaces/RunQueueEntry.html#wasCanceled\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":29,\"kind\":2048,\"name\":\"wasCompleted\",\"url\":\"interfaces/RunQueueEntry.html#wasCompleted\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":30,\"kind\":2048,\"name\":\"wasStarted\",\"url\":\"interfaces/RunQueueEntry.html#wasStarted\",\"classes\":\"tsd-kind-method tsd-parent-kind-interface\",\"parent\":\"RunQueueEntry\"},{\"id\":31,\"kind\":256,\"name\":\"RunQueueOptions\",\"url\":\"interfaces/RunQueueOptions.html\",\"classes\":\"tsd-kind-interface\"},{\"id\":32,\"kind\":1024,\"name\":\"continuousWorkMaxEntries\",\"url\":\"interfaces/RunQueueOptions.html#continuousWorkMaxEntries\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueOptions\"},{\"id\":33,\"kind\":1024,\"name\":\"continuousWorkTimeLimitMSec\",\"url\":\"interfaces/RunQueueOptions.html#continuousWorkTimeLimitMSec\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueOptions\"},{\"id\":34,\"kind\":1024,\"name\":\"maxParallel\",\"url\":\"interfaces/RunQueueOptions.html#maxParallel\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueOptions\"},{\"id\":35,\"kind\":256,\"name\":\"RunQueueScheduleOptions\",\"url\":\"interfaces/RunQueueScheduleOptions.html\",\"classes\":\"tsd-kind-interface\"},{\"id\":36,\"kind\":1024,\"name\":\"delayMSec\",\"url\":\"interfaces/RunQueueScheduleOptions.html#delayMSec\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueScheduleOptions\"},{\"id\":37,\"kind\":1024,\"name\":\"neverCancel\",\"url\":\"interfaces/RunQueueScheduleOptions.html#neverCancel\",\"classes\":\"tsd-kind-property tsd-parent-kind-interface\",\"parent\":\"RunQueueScheduleOptions\"}],\"index\":{\"version\":\"2.3.9\",\"fields\":[\"name\",\"parent\"],\"fieldVectors\":[[\"name/0\",[0,32.581]],[\"parent/0\",[]],[\"name/1\",[1,32.581]],[\"parent/1\",[]],[\"name/2\",[2,32.581]],[\"parent/2\",[]],[\"name/3\",[3,17.918]],[\"parent/3\",[]],[\"name/4\",[4,32.581]],[\"parent/4\",[3,1.414]],[\"name/5\",[5,32.581]],[\"parent/5\",[3,1.414]],[\"name/6\",[6,32.581]],[\"parent/6\",[3,1.414]],[\"name/7\",[7,32.581]],[\"parent/7\",[3,1.414]],[\"name/8\",[8,32.581]],[\"parent/8\",[3,1.414]],[\"name/9\",[9,32.581]],[\"parent/9\",[]],[\"name/10\",[10,32.581]],[\"parent/10\",[]],[\"name/11\",[11,32.581]],[\"parent/11\",[]],[\"name/12\",[12,32.581]],[\"parent/12\",[]],[\"name/13\",[13,32.581]],[\"parent/13\",[]],[\"name/14\",[14,32.581]],[\"parent/14\",[]],[\"name/15\",[15,14.123]],[\"parent/15\",[]],[\"name/16\",[16,32.581]],[\"parent/16\",[15,1.115]],[\"name/17\",[17,27.473]],[\"parent/17\",[15,1.115]],[\"name/18\",[18,27.473]],[\"parent/18\",[15,1.115]],[\"name/19\",[19,27.473]],[\"parent/19\",[15,1.115]],[\"name/20\",[20,32.581]],[\"parent/20\",[15,1.115]],[\"name/21\",[21,32.581]],[\"parent/21\",[15,1.115]],[\"name/22\",[22,32.581]],[\"parent/22\",[15,1.115]],[\"name/23\",[23,32.581]],[\"parent/23\",[15,1.115]],[\"name/24\",[24,32.581]],[\"parent/24\",[]],[\"name/25\",[25,17.918]],[\"parent/25\",[]],[\"name/26\",[26,32.581]],[\"parent/26\",[25,1.414]],[\"name/27\",[27,32.581]],[\"parent/27\",[25,1.414]],[\"name/28\",[28,32.581]],[\"parent/28\",[25,1.414]],[\"name/29\",[29,32.581]],[\"parent/29\",[25,1.414]],[\"name/30\",[30,32.581]],[\"parent/30\",[25,1.414]],[\"name/31\",[31,21.595]],[\"parent/31\",[]],[\"name/32\",[17,27.473]],[\"parent/32\",[31,1.705]],[\"name/33\",[18,27.473]],[\"parent/33\",[31,1.705]],[\"name/34\",[19,27.473]],[\"parent/34\",[31,1.705]],[\"name/35\",[32,24.108]],[\"parent/35\",[]],[\"name/36\",[33,32.581]],[\"parent/36\",[32,1.903]],[\"name/37\",[34,32.581]],[\"parent/37\",[32,1.903]]],\"invertedIndex\":[[\"cancel\",{\"_index\":27,\"name\":{\"27\":{}},\"parent\":{}}],[\"cancelall\",{\"_index\":21,\"name\":{\"21\":{}},\"parent\":{}}],[\"canceled\",{\"_index\":14,\"name\":{\"14\":{}},\"parent\":{}}],[\"constructor\",{\"_index\":16,\"name\":{\"16\":{}},\"parent\":{}}],[\"continuousworkmaxentries\",{\"_index\":17,\"name\":{\"17\":{},\"32\":{}},\"parent\":{}}],[\"continuousworktimelimitmsec\",{\"_index\":18,\"name\":{\"18\":{},\"33\":{}},\"parent\":{}}],[\"default_priority\",{\"_index\":12,\"name\":{\"12\":{}},\"parent\":{}}],[\"delaymsec\",{\"_index\":33,\"name\":{\"36\":{}},\"parent\":{}}],[\"getqueuelength\",{\"_index\":22,\"name\":{\"22\":{}},\"parent\":{}}],[\"getstatshandler\",{\"_index\":9,\"name\":{\"9\":{}},\"parent\":{}}],[\"id\",{\"_index\":20,\"name\":{\"20\":{}},\"parent\":{}}],[\"maxparallel\",{\"_index\":19,\"name\":{\"19\":{},\"34\":{}},\"parent\":{}}],[\"nevercancel\",{\"_index\":34,\"name\":{\"37\":{}},\"parent\":{}}],[\"promise\",{\"_index\":26,\"name\":{\"26\":{}},\"parent\":{}}],[\"resetrunafterinteractions\",{\"_index\":1,\"name\":{\"1\":{}},\"parent\":{}}],[\"resetstatshandler\",{\"_index\":10,\"name\":{\"10\":{}},\"parent\":{}}],[\"runafterinteractions\",{\"_index\":0,\"name\":{\"0\":{}},\"parent\":{}}],[\"runqueue\",{\"_index\":15,\"name\":{\"15\":{}},\"parent\":{\"16\":{},\"17\":{},\"18\":{},\"19\":{},\"20\":{},\"21\":{},\"22\":{},\"23\":{}}}],[\"runqueueentry\",{\"_index\":25,\"name\":{\"25\":{}},\"parent\":{\"26\":{},\"27\":{},\"28\":{},\"29\":{},\"30\":{}}}],[\"runqueueentryresult\",{\"_index\":24,\"name\":{\"24\":{}},\"parent\":{}}],[\"runqueueoptions\",{\"_index\":31,\"name\":{\"31\":{}},\"parent\":{\"32\":{},\"33\":{},\"34\":{}}}],[\"runqueuescheduleoptions\",{\"_index\":32,\"name\":{\"35\":{}},\"parent\":{\"36\":{},\"37\":{}}}],[\"schedule\",{\"_index\":23,\"name\":{\"23\":{}},\"parent\":{}}],[\"setrunafterinteractions\",{\"_index\":2,\"name\":{\"2\":{}},\"parent\":{}}],[\"setstatshandler\",{\"_index\":11,\"name\":{\"11\":{}},\"parent\":{}}],[\"statshandler\",{\"_index\":3,\"name\":{\"3\":{}},\"parent\":{\"4\":{},\"5\":{},\"6\":{},\"7\":{},\"8\":{}}}],[\"trackrunqueuedidcancelallcancelableentries\",{\"_index\":4,\"name\":{\"4\":{}},\"parent\":{}}],[\"trackrunqueuedidcancelentry\",{\"_index\":5,\"name\":{\"5\":{}},\"parent\":{}}],[\"trackrunqueuedidcompleteiteration\",{\"_index\":6,\"name\":{\"6\":{}},\"parent\":{}}],[\"trackrunqueuedidprocessentry\",{\"_index\":7,\"name\":{\"7\":{}},\"parent\":{}}],[\"trackrunqueuedidschedule\",{\"_index\":8,\"name\":{\"8\":{}},\"parent\":{}}],[\"ui_priority\",{\"_index\":13,\"name\":{\"13\":{}},\"parent\":{}}],[\"wascanceled\",{\"_index\":28,\"name\":{\"28\":{}},\"parent\":{}}],[\"wascompleted\",{\"_index\":29,\"name\":{\"29\":{}},\"parent\":{}}],[\"wasstarted\",{\"_index\":30,\"name\":{\"30\":{}},\"parent\":{}}]],\"pipeline\":[]}}");

@@ -36,3 +36,5 @@ import type { RunQueueEntry } from './types/entry';

private readonly processQueue;
private readonly scheduleAfterDelay;
private readonly scheduleImmediately;
}
//# sourceMappingURL=queue.d.ts.map

@@ -21,5 +21,2 @@ "use strict";

const consts_2 = require("./internal/consts");
const placeholderCancel = () => false;
const placeholderResolve = () => { };
const placeholderReject = () => { };
class RunQueue {

@@ -61,59 +58,5 @@ // Constructor

*/
this.schedule = (priority, id, run, options = {}) => {
var _a, _b, _c;
const entry = {
id,
priority,
wasCanceled: false,
wasCompleted: false,
wasStarted: false,
neverCancel: (_a = options.neverCancel) !== null && _a !== void 0 ? _a : false,
run,
// These placeholder functions are immediately replaced inside the promise
cancel: placeholderCancel,
resolve: placeholderResolve,
reject: placeholderReject
};
const promise = new Promise((resolve) => {
entry.cancel = () => {
var _a, _b;
if (entry.wasCanceled || entry.wasCompleted || entry.neverCancel) {
return false;
}
entry.wasCanceled = true;
resolve({ ok: false, details: consts_1.CANCELED });
(_b = (_a = (0, stats_handler_1.getStatsHandler)()).trackRunQueueDidCancelEntry) === null || _b === void 0 ? void 0 : _b.call(_a, { runQueue: this, entryId: id });
return true;
};
entry.resolve = (value) => {
if (entry.wasCompleted || entry.wasCanceled) {
return;
}
entry.wasCompleted = true;
resolve({ ok: true, details: value });
};
entry.reject = (e) => {
if (entry.wasCompleted || entry.wasCanceled) {
return;
}
entry.wasCompleted = true;
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
resolve({ ok: false, details: e });
};
this.heap.push(entry);
});
if (this.processingCount < this.maxParallel) {
(0, run_after_interactions_1.runAfterInteractions)(this.id, this.processQueue);
}
(_c = (_b = (0, stats_handler_1.getStatsHandler)()).trackRunQueueDidSchedule) === null || _c === void 0 ? void 0 : _c.call(_b, { runQueue: this, entryId: id });
return {
promise,
cancel: () => {
entry.cancel();
},
wasCanceled: () => entry.wasCanceled,
wasCompleted: () => entry.wasCompleted,
wasStarted: () => entry.wasStarted
};
};
this.schedule = (priority, id, run, options = {}) => options.delayMSec === undefined
? this.scheduleImmediately(priority, id, run, options)
: this.scheduleAfterDelay(priority, id, run, options);
// Private Methods

@@ -168,2 +111,104 @@ this.getNextEntry = () => {

});
this.scheduleAfterDelay = (priority, id, run, options) => {
let wasCanceled = false;
let wasResolved = false;
let runQueueEntry;
let resolver;
const timeout = setTimeout(() => __awaiter(this, void 0, void 0, function* () {
runQueueEntry = this.scheduleImmediately(priority, id, run, options);
try {
const result = yield runQueueEntry.promise;
if (wasResolved) {
return;
}
wasResolved = true;
resolver(result);
}
catch (e) {
// This shouldn't ever really happen since RunQueue doesn't throw, but just in case
if (wasResolved) {
return;
}
wasResolved = true;
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
resolver({ ok: false, details: e });
}
}), options.delayMSec);
return {
cancel: () => {
if (wasResolved) {
return;
}
wasResolved = true;
if (!wasCanceled) {
wasCanceled = true;
clearTimeout(timeout);
runQueueEntry === null || runQueueEntry === void 0 ? void 0 : runQueueEntry.cancel();
runQueueEntry = undefined;
}
resolver({ ok: false, details: consts_1.CANCELED });
},
promise: new Promise((resolve) => {
resolver = resolve;
}),
wasCanceled: () => { var _a; return wasCanceled || ((_a = runQueueEntry === null || runQueueEntry === void 0 ? void 0 : runQueueEntry.wasCanceled()) !== null && _a !== void 0 ? _a : false); },
wasCompleted: () => { var _a; return (_a = runQueueEntry === null || runQueueEntry === void 0 ? void 0 : runQueueEntry.wasCompleted()) !== null && _a !== void 0 ? _a : false; },
wasStarted: () => { var _a; return (_a = runQueueEntry === null || runQueueEntry === void 0 ? void 0 : runQueueEntry.wasStarted()) !== null && _a !== void 0 ? _a : false; }
};
};
this.scheduleImmediately = (priority, id, run, options) => {
var _a, _b, _c;
let resolver;
const entry = {
id,
priority,
wasCanceled: false,
wasCompleted: false,
wasStarted: false,
neverCancel: (_a = options.neverCancel) !== null && _a !== void 0 ? _a : false,
run,
cancel: () => {
var _a, _b;
if (entry.wasCanceled || entry.wasCompleted || entry.neverCancel) {
return false;
}
entry.wasCanceled = true;
resolver({ ok: false, details: consts_1.CANCELED });
(_b = (_a = (0, stats_handler_1.getStatsHandler)()).trackRunQueueDidCancelEntry) === null || _b === void 0 ? void 0 : _b.call(_a, { runQueue: this, entryId: id });
return true;
},
resolve: (value) => {
if (entry.wasCompleted || entry.wasCanceled) {
return;
}
entry.wasCompleted = true;
resolver({ ok: true, details: value });
},
reject: (e) => {
if (entry.wasCompleted || entry.wasCanceled) {
return;
}
entry.wasCompleted = true;
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
resolver({ ok: false, details: e });
}
};
const promise = new Promise((resolve) => {
resolver = resolve;
});
this.heap.push(entry);
if (this.processingCount < this.maxParallel) {
(0, run_after_interactions_1.runAfterInteractions)(this.id, this.processQueue);
}
(_c = (_b = (0, stats_handler_1.getStatsHandler)()).trackRunQueueDidSchedule) === null || _c === void 0 ? void 0 : _c.call(_b, { runQueue: this, entryId: id });
return {
promise,
cancel: () => {
entry.cancel();
},
wasCanceled: () => entry.wasCanceled,
wasCompleted: () => entry.wasCompleted,
wasStarted: () => entry.wasStarted
};
};
this.continuousWorkMaxEntries = (_a = options.continuousWorkMaxEntries) !== null && _a !== void 0 ? _a : Number.MAX_SAFE_INTEGER;

@@ -170,0 +215,0 @@ this.continuousWorkTimeLimitMSec = (_b = options.continuousWorkTimeLimitMSec) !== null && _b !== void 0 ? _b : consts_2.DEFAULT_CONTINUOUS_WORK_TIME_LIMIT_MSEC;

/** Options to effect the processing of this entry */
export interface RunQueueScheduleOptions {
/** If specified, the entry isn't scheduled until after an initial delay */
delayMSec?: number;
/**

@@ -4,0 +6,0 @@ * If `true`, this entry ignores cancelation attempts.

{
"name": "client-run-queue",
"version": "1.0.0",
"version": "1.1.0",
"description": "A client-friendly run queue",

@@ -5,0 +5,0 @@ "keywords": ["promise", "concurrency", "limit", "throttle", "queue", "priority", "typescript", "client"],

@@ -41,5 +41,5 @@ # client-run-queue

// Scheduling more entries using different priorities and marking one as non-cancelable
// Scheduling more entries using different priorities and options
q.schedule(2, 'my-function', doSomeWork);
q.schedule(2, 'my-function', doSomeWork, { delayMSec: 1000 });
q.schedule(0, 'my-function', doSomeWork, { neverCancel: true });

@@ -94,2 +94,2 @@ q.schedule(1, 'my-function', doSomeWork);

client-run-queue is maintained by the team at [Passfolio](passfolio.com).
client-run-queue is maintained by the team at [Passfolio](https://www.passfolio.com).

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