333

schangxiang@126.com

2025-09-19 18966e02fb573c7e2bb0c6426ed792b38b910940

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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
/* global describe:true, beforeEach:true, it:true */
 
var chan   = require('..')
var expect = require('expect.js')
var fs     = require('fs')
 
describe('Channel make', function () {
 
  it(
    'should return a channel function',
    function () {
      var ch = chan()
      expect(ch).to.be.a(Function)
    }
  )
 
})
 
describe('A channel', function () {
 
  var ch
 
  beforeEach(function () {
    ch = chan()
  })
 
  it(
    'should receive a value of any non-function type as the first argument',
    function () {
      var typeCases = [
        1,
        'foo',
        [1, 2 , 3],
        {foo: 'bar'},
        true,
        false,
        null,
        void 0
      ]
      typeCases.forEach(function (val) {
        ch(val)
        ch(function (err, result) {
          expect(result).to.be(val)
        })
      })
    }
  )
 
  it(
    'should receive a function value as a second argument if the first is null',
    function () {
      ch(null, function () {})
      ch(function (err, result) {
        expect(result).to.be.a(Function)
      })
    }
  )
 
  it(
    'should queue values until they are yielded/removed',
    function () {
      var values = [1, 2, 3, 4, 5]
      values.forEach(function (value) {
        ch(value)
      })
      values.forEach(function (value) {
        ch(function (err, result) {
          expect(result).to.be(value)
        })
      })
    }
  )
 
  it(
    'should queue callbacks until values are added',
    function () {
      var values = [1, 2, 3, 4, 5]
      values.forEach(function (value) {
        ch(function (err, result) {
          expect(result).to.be(value)
        })
      })
      values.forEach(function (value) {
        ch(value)
      })
    }
  )
 
  it(
    'should pass errors as the first argument to callbacks',
    function () {
      var e = new Error('Foo')
      ch(e)
      ch(function (err) {
        expect(err).to.be(e)
      })
    }
  )
 
  it(
    'should be useable directly as a callback for node style async functions',
    function (done) {
      ch(function (err, contents) {
        expect(err).to.be(null)
        expect(contents).to.be.a(Buffer)
        done()
      })
      fs.readFile(__filename, ch)
    }
  )
 
})