mirror of
https://github.com/lingble/clickhouse.git
synced 2025-11-03 20:47:58 +00:00
Merge pull request #113 from 1u0n/cleanup-listeners
avoid too many event listeners
This commit is contained in:
14
index.js
14
index.js
@@ -302,12 +302,16 @@ class Rs extends Transform {
|
|||||||
return Promise.resolve();
|
return Promise.resolve();
|
||||||
} else {
|
} else {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
this.ws.once('error', err => reject(err));
|
const fn = err => reject(err);
|
||||||
|
this.ws.once('error', fn);
|
||||||
this.ws.once('drain', err => {
|
this.ws.once('drain', err => {
|
||||||
if (err) return reject(err);
|
this.ws.removeListener('error', fn);
|
||||||
|
if (err) {
|
||||||
resolve();
|
reject(err);
|
||||||
})
|
} else {
|
||||||
|
resolve();
|
||||||
|
}
|
||||||
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user