Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
d565b3f42d | |||
a2aab715ed |
|
@ -1,6 +1,6 @@
|
||||||
{
|
{
|
||||||
"name": "node-eventstore-client",
|
"name": "node-eventstore-client",
|
||||||
"version": "0.1.9",
|
"version": "0.1.11",
|
||||||
"description": "A port of the EventStore .Net ClientAPI to Node.js",
|
"description": "A port of the EventStore .Net ClientAPI to Node.js",
|
||||||
"main": "index.js",
|
"main": "index.js",
|
||||||
"types": "index.d.ts",
|
"types": "index.d.ts",
|
||||||
|
|
|
@ -43,6 +43,7 @@ const EmptyGuid = '00000000-0000-0000-0000-000000000000';
|
||||||
* @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();
|
||||||
|
|
|
@ -37,6 +37,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