client-run-queue
Advanced tools
Comparing version 1.0.0 to 1.1.0
@@ -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
326921
73
3279