All files runtime.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
 
 
 
 
 
 
 
10x
 
 
 
 
3x
 
 
10x
16x
18x
 
 
 
 
10x
 
 
/**
 * @file src/runtime.js
 * @copyright Karim Alibhai. All rights reserved.
 */
 
import { kQueue } from './symbols'
 
export function createJobProxy(queue) {
	const jobs = {
		[kQueue]: queue,
		$: {
			size: queue.size.bind(queue),
		},
		destroy: () => queue.destroy(),
	}
 
	for (const [name, fn] of queue.jobs.entries()) {
		jobs[name] = {
			Enqueue: (data, options) => queue.Enqueue(name, data, options),
			Execute: fn,
		}
	}
 
	return jobs
}