text: var helper = require(__dirname + '/test-helper')
  
  var called = false;
  test('disconnects', function() {
    var sink = new helper.Sink(4, function() {
      called = true;
      //this should exit the process, killing each connection pool
      helper.pg.end();
    });
    [helper.config, helper.config, helper.config, helper.config].forEach(function(config) {
      helper.pg.connect(config, function(err, client) {
        assert.isNull(err);
        client.query("SELECT * FROM NOW()", function(err, result) {
          process.nextTick(function() {
            assert.equal(called, false, "Should not have disconnected yet")
            sink.add();
          })
        })
      })
    })
  })
  
  
  