javascript - エミッターからの「終了」シグナルをモックしますが、呼び出されません

Question

mocha + unit.js + proxyquire で単体テストを行っています。今、私は嘲笑されたエミッターで立ち往生しています。「行」信号の偽物である最初のモックエミッター、それは行われました。2番目のものは、最初のものと同じようにフォローしました。大きな違いはないのですが、ここで質問があります。

なぜエミッターは「終わり」を出さないのですか?

userHandler_post.js :

var pg = require('pg');
var connectionString = require('./postgres.ini');
var pgdown = require('./pgdown.js');

exports.post = function(req,res, callback){
    var cb_is_func = (typeof(callback)==='function');
    // Grab data from http request
    var adata = [req.body.username, 
         req.body.password,
         req.body.privilege,
         req.body.firstname,    
         req.body.middlename,   
         req.body.lastname,
         req.body.streetaddress, //rename
         req.body.subdistrict,      
         req.body.district,     
         req.body.province,
         req.body.country,          
         req.body.zipcode,
         req.body.email,
         req.body.phonecountrycode,
         req.body.phoneareacode,
         req.body.phonenumber, //rename
         req.body.faxcountrycode,
         req.body.faxareacode,
         req.body.faxnumber]; //rename

    // Get a Postgres client from the connection pool
    pg.connect(connectionString, function(err, client, done) {

    // Handle Errors
    if(err) {
        done();
        pgdown.pgdown(res);
        if(cb_is_func){callback();}
    }else{

        // SQL Query > Insert Data
        var func_ = 'SELECT Dugong.Users_Add($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13,$14,$15,$16,$17,$18,$19)';
        var addUser_ = client.query(func_, adata);

        addUser_.on('error', function(error){
        var data = {success : false, 
                username : req.body.username,
                reason : {errmsg : 'Unable to add user',
                      errid : 'addUser_' }};
        done();
        res.json(data);
        if(cb_is_func){callback(data);}
        });

        addUser_.on('end',function(result){
        var data = {success : true, username : req.body.username};
        done();
        res.json(data);
        if(cb_is_func){callback(data);}
        });
    }
    });
    pg.end();
};

userHandler_post.test.js :

var httpMocks = require('node-mocks-http');
var test = require('unit.js');

var real_userHandler = require('../routes/userHandler_post.js');

var proxyquire =  require('proxyquire'),
        pgStub   =  { };

var events = require('events');


describe('userHandler_post : ', function () {

    var request;
    beforeEach(function (){
            request  = httpMocks.createRequest({
          method: 'POST',
          url: '/users',
          body : { Username : 'Yoda', 
                                ... //Omit to save question lines.
                                FaxNum: '',
                            }
    });
    });

    it('should show connetion error. If cannot connect to database.', function (done) {

        pgStub.connect = function (aconnectionString, cb){
            cb('Connection refused',null,null); 
        };

    var response = httpMocks.createResponse();

    var userHandler_post = proxyquire('../routes/userHandler_post.js', { 'pg' : pgStub} );

    userHandler_post.post(request,response);    //Let it update response
        var answer = response._getData();
        test.value(answer).match('Connection refused');

        done(); //Need
    });

    it('should show query error. If database rejects query.', function (done) {

        pgStub.connect = function (aconnectionString, cb){
            var client = {};
            client.query = function(querystr){
                var emitter = new events.EventEmitter();

                setTimeout(function() {
                    emitter.emit('error', {detail: 'Query error'})
                }, 0);      

                return emitter; 
            };

            var done = function(){};    
            cb(null,client,done);

        };

        var response = httpMocks.createResponse();

    var userHandler_post = proxyquire('../routes/userHandler_post.js', { 'pg' : pgStub} );

    userHandler_post.post(request, response, function(){
            var answer = response._getData();
            test.value(answer).match('Query error');
    });

        done(); //Need
    });

    it('should show several records. If database processes query.', function (done) {

        pgStub.connect = function (aconnectionString, cb){
            var client = {};
            client.query = function(querystr){

                var emitter = new events.EventEmitter();
                console.log('below emitter');

                setTimeout(function() {
                    console.log('-*************--');
                    emitter.emit('end', {a : 1});   
                }, 0);      //

                return emitter; 
            };

            var done = function(){};
            cb(null, client, done);

        };

        var response = httpMocks.createResponse();

    var userHandler_post = proxyquire('../routes/userHandler_post.js', { 'pg' : pgStub} );

        userHandler_post.post(request, response, function(){
            var answer = response._getData();
            console.log(answer);
//          test.value(answer).match('Connection refused');
    });

//      console.log(response._getData());
        done(); //Need
    });

});

---

ターミナル ：

mocha testing/userHandler_post.test.js


  userHandler_post : 
    ✓ should show connetion error. If cannot connect to database.
    ✓ should show query error. If database rejects query.
below emitter
    ✓ should show several records. If database processes query.


  3 passing (10ms)

それが本当に「終了」信号を発したかどうか。次に、「レコードの挿入が完了しました」と表示されます。