1 | /*!
|
2 | * The MIT License (MIT)
|
3 | *
|
4 | * Copyright (c) 2019 Mark van Seventer
|
5 | *
|
6 | * Permission is hereby granted, free of charge, to any person obtaining a copy of
|
7 | * this software and associated documentation files (the "Software"), to deal in
|
8 | * the Software without restriction, including without limitation the rights to
|
9 | * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
|
10 | * the Software, and to permit persons to whom the Software is furnished to do so,
|
11 | * subject to the following conditions:
|
12 | *
|
13 | * The above copyright notice and this permission notice shall be included in all
|
14 | * copies or substantial portions of the Software.
|
15 | *
|
16 | * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
17 | * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
|
18 | * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
|
19 | * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
|
20 | * IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
21 | * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
22 | */
|
23 |
|
24 | // Strict mode.
|
25 |
|
26 |
|
27 | // Configure.
|
28 | const queue = []
|
29 |
|
30 | // Extend object.
|
31 | Object.defineProperties(queue, {
|
32 | // Add drain handler.
|
33 | drain: {
|
34 | value: (initialValue) => queue.reduce((acc, [, cb]) => cb(acc), initialValue)
|
35 | },
|
36 |
|
37 | // Add pipeline getter.
|
38 | pipeline: {
|
39 | get: () => queue.map(([value]) => value)
|
40 | }
|
41 | })
|
42 |
|
43 | // Exports.
|
44 | module.exports = queue
|