ysjj-system/node_modules/chan/test/close.js

/* global describe:true, beforeEach:true, it:true */

var chan   = require('..')
var expect = require('expect.js')

describe('A closed channel', function () {

  it(
    'should yield an error when attempting to add a value',
    function () {
      var ch = chan()
      ch.close()
      ch('foo')(function (err) {
        expect(err).to.be.an(Error)
      })
    }
  )

  describe('that is has items in the buffer', function () {

    it(
      'should return `false` when the `done()` method is called',
      function () {
        var ch = chan(1)
        ch('foo')
        ch.close()
        expect(ch.done()).to.be(false)
      }
    )

  })

  describe('that is empty', function () {

    it(
      'should invoke peding callbacks with empty value',
      function () {
        var ch = chan()
        ch(function (err, value) {
          expect(value).to.be(ch.empty)
        })
        ch.close()
      }
    )

    it(
      'should return `true` when the `done()` method is called',
      function () {
        var ch = chan()
        ch.close()
        expect(ch.done()).to.be(true)
      }
    )

    it(
      'should immediately invoke any callback added with the empty value',
      function () {
        var ch = chan()
        ch.close()
        ch(function (err, value) {
          expect(value).to.be(ch.empty)
        })
      }
    )

  })

})