test: added integration test for end event of the stream

test/integration/test-pool-end.js

@@ -0,0 +1,22 @@
+'use strict';
+
+const { createPool } = require('../common.js');
+const assert = require('assert');
+
+const pool = createPool();
+
+pool.getConnection((err, conn) => {
+  assert.ifError(err);
+
+  assert(pool._allConnections.length === 1);
+  assert(pool._freeConnections.length === 0);
+
+  // emit the end event, so the connection gets removed from the pool
+  conn.stream.emit('end');
+
+  assert(pool._allConnections.length === 0);
+  assert(pool._freeConnections.length === 0);
+
+  // As the connection has not really ended we need to this ourselves
+  conn.destroy();
+});