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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
| 'use strict'
|
| const { test } = require('tap')
| const enqueue = require('../../../../lib/client/request-queue/enqueue')
|
| test('rejects new requests if size is exceeded', async t => {
| const q = { _queue: { size: 5 }, size: 5 }
| const result = enqueue.call(q, 'foo', 'bar', {}, {})
| t.notOk(result)
| })
|
| test('rejects new requests if queue is frozen', async t => {
| const q = { _queue: { size: 0 }, size: 5, _frozen: true }
| const result = enqueue.call(q, 'foo', 'bar', {}, {})
| t.notOk(result)
| })
|
| test('adds a request and returns if no timeout', async t => {
| const q = {
| _queue: {
| size: 0,
| add (obj) {
| t.same(obj, {
| message: 'foo',
| expect: 'bar',
| emitter: 'baz',
| cb: 'bif'
| })
| }
| },
| _frozen: false,
| timeout: 0
| }
| const result = enqueue.call(q, 'foo', 'bar', 'baz', 'bif')
| t.ok(result)
| })
|
| test('adds a request and returns timer not set', async t => {
| const q = {
| _queue: {
| size: 0,
| add (obj) {
| t.same(obj, {
| message: 'foo',
| expect: 'bar',
| emitter: 'baz',
| cb: 'bif'
| })
| }
| },
| _frozen: false,
| timeout: 100,
| _timer: null
| }
| const result = enqueue.call(q, 'foo', 'bar', 'baz', 'bif')
| t.ok(result)
| })
|
| test('adds a request, returns true, and clears queue', t => {
| // Must not be an async test due to an internal `setTimeout`
| t.plan(4)
| const q = {
| _queue: {
| size: 0,
| add (obj) {
| t.same(obj, {
| message: 'foo',
| expect: 'bar',
| emitter: 'baz',
| cb: 'bif'
| })
| }
| },
| _frozen: false,
| timeout: 5,
| _timer: 123,
| freeze () { t.pass() },
| purge () { t.pass() }
| }
| const result = enqueue.call(q, 'foo', 'bar', 'baz', 'bif')
| t.ok(result)
| })
|
|
