Fix potential error handling bug due to missing EventEmitter.call(this) in EventStoreNodeConnection and EventStoreConnectionLogicHandler
This commit is contained in:
parent
8997a8c398
commit
67dd275b5d
|
@ -47,6 +47,7 @@ const ClientVersion = 1;
|
||||||
* @property {Number} totalOperationCount
|
* @property {Number} totalOperationCount
|
||||||
*/
|
*/
|
||||||
function EventStoreConnectionLogicHandler(esConnection, settings) {
|
function EventStoreConnectionLogicHandler(esConnection, settings) {
|
||||||
|
EventEmitter.call(this);
|
||||||
this._esConnection = esConnection;
|
this._esConnection = esConnection;
|
||||||
this._settings = settings;
|
this._settings = settings;
|
||||||
this._queue = new SimpleQueuedHandler();
|
this._queue = new SimpleQueuedHandler();
|
||||||
|
|
|
@ -38,6 +38,7 @@ const MaxReadSize = 4096;
|
||||||
* @constructor
|
* @constructor
|
||||||
*/
|
*/
|
||||||
function EventStoreNodeConnection(settings, clusterSettings, endpointDiscoverer, connectionName) {
|
function EventStoreNodeConnection(settings, clusterSettings, endpointDiscoverer, connectionName) {
|
||||||
|
EventEmitter.call(this);
|
||||||
this._connectionName = connectionName || ['ES-', uuid.v4()].join('');
|
this._connectionName = connectionName || ['ES-', uuid.v4()].join('');
|
||||||
this._settings = settings;
|
this._settings = settings;
|
||||||
this._clusterSettings = clusterSettings;
|
this._clusterSettings = clusterSettings;
|
||||||
|
|
Loading…
Reference in New Issue
Block a user