remove forwardPoolErrors

src/hashpool.ts

@@ -19,7 +19,7 @@
 	retries: number;
 	opts: HashPoolOptions;
 
 	constructor( nodes: Array<string>, opts?: any ) {
 		super();
 
 		this.retries = 0;
@@ -30,7 +30,7 @@
 			retry: ( retries: number ): number => {
 				const exp = Math.pow( 2, retries ) * 250;
 
 				// exponential backoff up to 30 seconds
 				return Math.min( exp, 30000 );
 			},
 			pingInterval: 60_000,
@@ -47,8 +47,6 @@
 			socketTimeout: 100,
 		}, opts );
 
-		this.opts.forwardPoolErrors = true;
-
 		// initialize hash pool
 		for ( const node of nodes ) {
 			this.connect( node );

src/pool.ts

@@ -11,7 +11,6 @@
 	idleTimeoutMillis: number;
 
 	// internal
-	forwardPoolErrors: boolean;
 	autostart: boolean;
 	fifo: boolean;
 	evictionRunIntervalMillis: number;
@@ -21,12 +20,10 @@
 	pool: GenericPool<Memcached>;
 	opts: PoolOptions;
 
 	constructor( port: number, host: string, opts?: any ) {
 		super();
 
 		this.opts = Object.assign( {
-			forwardPoolErrors: false,
-
 			// Pool options
 			max: 10,
 			min: 2,
@@ -46,9 +43,11 @@
 		this.pool = createPool( {
 			create: async () => {
 				const memcached = new Memcached( port, host, this.opts );
-				if ( this.opts.forwardPoolErrors ) {
-					memcached.on( 'error', ( error: Error ) => this.emit( 'error', error ) );
-				}
+				memcached.on( 'error', ( error: Error ) => {
+					if ( this.listeners( 'error' ).length ) {
+						this.emit( 'error', error );
+					}
+				} );
 
 				await memcached.ready();
 				return memcached;