lib,src: remove usage of events.EventEmitter
The `events` module already exports `EventEmitter` constructor function So, we don't have to use `events.EventEmitter` to access it. Refer: https://github.com/nodejs/node/pull/2896 PR-URL: https://github.com/nodejs/node/pull/2921 Reviewed-By: Roman Reiss <me@silverwind.io> Reviewed-By: Michaël Zasso <mic.besace@gmail.com>
This commit is contained in:
parent
7953c83b85
commit
f32a606e37
@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
const net = require('net');
|
const net = require('net');
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
const EventEmitter = require('events').EventEmitter;
|
const EventEmitter = require('events');
|
||||||
const debug = util.debuglog('http');
|
const debug = util.debuglog('http');
|
||||||
|
|
||||||
// New Agent code.
|
// New Agent code.
|
||||||
|
@ -3,7 +3,7 @@
|
|||||||
const util = require('util');
|
const util = require('util');
|
||||||
const net = require('net');
|
const net = require('net');
|
||||||
const url = require('url');
|
const url = require('url');
|
||||||
const EventEmitter = require('events').EventEmitter;
|
const EventEmitter = require('events');
|
||||||
const HTTPParser = process.binding('http_parser').HTTPParser;
|
const HTTPParser = process.binding('http_parser').HTTPParser;
|
||||||
const assert = require('assert').ok;
|
const assert = require('assert').ok;
|
||||||
const common = require('_http_common');
|
const common = require('_http_common');
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
const net = require('net');
|
const net = require('net');
|
||||||
const EventEmitter = require('events').EventEmitter;
|
const EventEmitter = require('events');
|
||||||
const HTTPParser = process.binding('http_parser').HTTPParser;
|
const HTTPParser = process.binding('http_parser').HTTPParser;
|
||||||
const assert = require('assert').ok;
|
const assert = require('assert').ok;
|
||||||
const common = require('_http_common');
|
const common = require('_http_common');
|
||||||
@ -117,7 +117,8 @@ function onServerResponseClose() {
|
|||||||
// array. That is, in the example below, b still gets called even though
|
// array. That is, in the example below, b still gets called even though
|
||||||
// it's been removed by a:
|
// it's been removed by a:
|
||||||
//
|
//
|
||||||
// var obj = new events.EventEmitter;
|
// var EventEmitter = require('events');
|
||||||
|
// var obj = new EventEmitter();
|
||||||
// obj.on('event', a);
|
// obj.on('event', a);
|
||||||
// obj.on('event', b);
|
// obj.on('event', b);
|
||||||
// function a() { obj.removeListener('event', b) }
|
// function a() { obj.removeListener('event', b) }
|
||||||
|
@ -3,7 +3,7 @@
|
|||||||
module.exports = Readable;
|
module.exports = Readable;
|
||||||
Readable.ReadableState = ReadableState;
|
Readable.ReadableState = ReadableState;
|
||||||
|
|
||||||
const EE = require('events').EventEmitter;
|
const EE = require('events');
|
||||||
const Stream = require('stream');
|
const Stream = require('stream');
|
||||||
const Buffer = require('buffer').Buffer;
|
const Buffer = require('buffer').Buffer;
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
'use strict';
|
'use strict';
|
||||||
|
|
||||||
const assert = require('assert');
|
const assert = require('assert');
|
||||||
const events = require('events');
|
const EventEmitter = require('events');
|
||||||
const stream = require('stream');
|
const stream = require('stream');
|
||||||
const tls = require('tls');
|
const tls = require('tls');
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
@ -672,7 +672,7 @@ function SecurePair(context, isServer, requestCert, rejectUnauthorized,
|
|||||||
|
|
||||||
options || (options = {});
|
options || (options = {});
|
||||||
|
|
||||||
events.EventEmitter.call(this);
|
EventEmitter.call(this);
|
||||||
|
|
||||||
this.server = options.server;
|
this.server = options.server;
|
||||||
this._secureEstablished = false;
|
this._secureEstablished = false;
|
||||||
@ -741,7 +741,7 @@ function SecurePair(context, isServer, requestCert, rejectUnauthorized,
|
|||||||
process.nextTick(securePairNT, this, options);
|
process.nextTick(securePairNT, this, options);
|
||||||
}
|
}
|
||||||
|
|
||||||
util.inherits(SecurePair, events.EventEmitter);
|
util.inherits(SecurePair, EventEmitter);
|
||||||
|
|
||||||
function securePairNT(self, options) {
|
function securePairNT(self, options) {
|
||||||
/* The Connection may be destroyed by an abort call */
|
/* The Connection may be destroyed by an abort call */
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
'use strict';
|
'use strict';
|
||||||
|
|
||||||
const EventEmitter = require('events').EventEmitter;
|
const EventEmitter = require('events');
|
||||||
const assert = require('assert');
|
const assert = require('assert');
|
||||||
const dgram = require('dgram');
|
const dgram = require('dgram');
|
||||||
const fork = require('child_process').fork;
|
const fork = require('child_process').fork;
|
||||||
|
@ -3,7 +3,7 @@
|
|||||||
const assert = require('assert');
|
const assert = require('assert');
|
||||||
const Buffer = require('buffer').Buffer;
|
const Buffer = require('buffer').Buffer;
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
const events = require('events');
|
const EventEmitter = require('events');
|
||||||
const constants = require('constants');
|
const constants = require('constants');
|
||||||
|
|
||||||
const UDP = process.binding('udp_wrap').UDP;
|
const UDP = process.binding('udp_wrap').UDP;
|
||||||
@ -79,7 +79,7 @@ exports._createSocketHandle = function(address, port, addressType, fd, flags) {
|
|||||||
|
|
||||||
|
|
||||||
function Socket(type, listener) {
|
function Socket(type, listener) {
|
||||||
events.EventEmitter.call(this);
|
EventEmitter.call(this);
|
||||||
|
|
||||||
if (typeof type === 'object') {
|
if (typeof type === 'object') {
|
||||||
var options = type;
|
var options = type;
|
||||||
@ -101,7 +101,7 @@ function Socket(type, listener) {
|
|||||||
if (typeof listener === 'function')
|
if (typeof listener === 'function')
|
||||||
this.on('message', listener);
|
this.on('message', listener);
|
||||||
}
|
}
|
||||||
util.inherits(Socket, events.EventEmitter);
|
util.inherits(Socket, EventEmitter);
|
||||||
exports.Socket = Socket;
|
exports.Socket = Socket;
|
||||||
|
|
||||||
|
|
||||||
|
@ -12,7 +12,7 @@ const constants = require('constants');
|
|||||||
const fs = exports;
|
const fs = exports;
|
||||||
const Buffer = require('buffer').Buffer;
|
const Buffer = require('buffer').Buffer;
|
||||||
const Stream = require('stream').Stream;
|
const Stream = require('stream').Stream;
|
||||||
const EventEmitter = require('events').EventEmitter;
|
const EventEmitter = require('events');
|
||||||
const FSReqWrap = binding.FSReqWrap;
|
const FSReqWrap = binding.FSReqWrap;
|
||||||
const FSEvent = process.binding('fs_event_wrap').FSEvent;
|
const FSEvent = process.binding('fs_event_wrap').FSEvent;
|
||||||
|
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
const internalUtil = require('internal/util');
|
const internalUtil = require('internal/util');
|
||||||
const EventEmitter = require('events').EventEmitter;
|
const EventEmitter = require('events');
|
||||||
|
|
||||||
|
|
||||||
exports.IncomingMessage = require('_http_incoming').IncomingMessage;
|
exports.IncomingMessage = require('_http_incoming').IncomingMessage;
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
const StringDecoder = require('string_decoder').StringDecoder;
|
const StringDecoder = require('string_decoder').StringDecoder;
|
||||||
const Buffer = require('buffer').Buffer;
|
const Buffer = require('buffer').Buffer;
|
||||||
const EventEmitter = require('events').EventEmitter;
|
const EventEmitter = require('events');
|
||||||
const net = require('net');
|
const net = require('net');
|
||||||
const dgram = require('dgram');
|
const dgram = require('dgram');
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
module.exports = {SocketListSend, SocketListReceive};
|
module.exports = {SocketListSend, SocketListReceive};
|
||||||
|
|
||||||
const EventEmitter = require('events').EventEmitter;
|
const EventEmitter = require('events');
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
|
|
||||||
// This object keep track of the socket there are sended
|
// This object keep track of the socket there are sended
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
'use strict';
|
'use strict';
|
||||||
|
|
||||||
const events = require('events');
|
const EventEmitter = require('events');
|
||||||
const stream = require('stream');
|
const stream = require('stream');
|
||||||
const timers = require('timers');
|
const timers = require('timers');
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
@ -1071,7 +1071,7 @@ function Server(options, connectionListener) {
|
|||||||
if (!(this instanceof Server))
|
if (!(this instanceof Server))
|
||||||
return new Server(options, connectionListener);
|
return new Server(options, connectionListener);
|
||||||
|
|
||||||
events.EventEmitter.call(this);
|
EventEmitter.call(this);
|
||||||
|
|
||||||
var self = this;
|
var self = this;
|
||||||
var options;
|
var options;
|
||||||
@ -1113,7 +1113,7 @@ function Server(options, connectionListener) {
|
|||||||
this.allowHalfOpen = options.allowHalfOpen || false;
|
this.allowHalfOpen = options.allowHalfOpen || false;
|
||||||
this.pauseOnConnect = !!options.pauseOnConnect;
|
this.pauseOnConnect = !!options.pauseOnConnect;
|
||||||
}
|
}
|
||||||
util.inherits(Server, events.EventEmitter);
|
util.inherits(Server, EventEmitter);
|
||||||
exports.Server = Server;
|
exports.Server = Server;
|
||||||
|
|
||||||
|
|
||||||
|
@ -12,7 +12,7 @@ const util = require('util');
|
|||||||
const internalUtil = require('internal/util');
|
const internalUtil = require('internal/util');
|
||||||
const inherits = util.inherits;
|
const inherits = util.inherits;
|
||||||
const Buffer = require('buffer').Buffer;
|
const Buffer = require('buffer').Buffer;
|
||||||
const EventEmitter = require('events').EventEmitter;
|
const EventEmitter = require('events');
|
||||||
|
|
||||||
|
|
||||||
exports.createInterface = function(input, output, completer, terminal) {
|
exports.createInterface = function(input, output, completer, terminal) {
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
module.exports = Stream;
|
module.exports = Stream;
|
||||||
|
|
||||||
const EE = require('events').EventEmitter;
|
const EE = require('events');
|
||||||
const util = require('util');
|
const util = require('util');
|
||||||
|
|
||||||
util.inherits(Stream, EE);
|
util.inherits(Stream, EE);
|
||||||
|
@ -10,7 +10,7 @@
|
|||||||
this.global = this;
|
this.global = this;
|
||||||
|
|
||||||
function startup() {
|
function startup() {
|
||||||
var EventEmitter = NativeModule.require('events').EventEmitter;
|
var EventEmitter = NativeModule.require('events');
|
||||||
|
|
||||||
process.__proto__ = Object.create(EventEmitter.prototype, {
|
process.__proto__ = Object.create(EventEmitter.prototype, {
|
||||||
constructor: {
|
constructor: {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user