http/tcp: remove reject listener on success.
This commit is contained in:
parent
c347add2fd
commit
906a6bf13a
@ -811,15 +811,13 @@ HTTPBase.prototype.address = function address() {
|
|||||||
|
|
||||||
HTTPBase.prototype.listen = function listen(port, host) {
|
HTTPBase.prototype.listen = function listen(port, host) {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
let addr;
|
this.server.once('error', reject);
|
||||||
|
|
||||||
this.server.once('error', reject)
|
|
||||||
|
|
||||||
this.server.listen(port, host, () => {
|
this.server.listen(port, host, () => {
|
||||||
addr = this.address();
|
let addr = this.address();
|
||||||
|
|
||||||
this.emit('listening', addr);
|
this.emit('listening', addr);
|
||||||
|
|
||||||
|
this.server.removeListener('error', reject);
|
||||||
resolve(addr);
|
resolve(addr);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|||||||
@ -41,8 +41,11 @@ tcp.createServer = function createServer() {
|
|||||||
|
|
||||||
ee.listen = function listen(port, host) {
|
ee.listen = function listen(port, host) {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
server.once('error', reject)
|
server.once('error', reject);
|
||||||
server.listen(port, host, resolve);
|
server.listen(port, host, () => {
|
||||||
|
server.removeListener('error', reject);
|
||||||
|
resolve();
|
||||||
|
});
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user