update test to run using async and through2
fix broken end call with callback

it was calling connection.end() instead of
pool.end()