@arque/core
Advanced tools
Comparing version 0.2.2 to 0.2.3
@@ -7,3 +7,2 @@ "use strict"; | ||
const debug_1 = tslib_1.__importDefault(require("debug")); | ||
const ramda_1 = tslib_1.__importDefault(require("ramda")); | ||
class Projection { | ||
@@ -24,3 +23,3 @@ constructor(store, stream, config, eventHandlers, _id, _state) { | ||
this.timestampLastEventReceived = Date.now(); | ||
this.eventHandlers = new Map(ramda_1.default.map((item) => [item.type, item], eventHandlers)); | ||
this.eventHandlers = new Map(eventHandlers.map(item => [item.type, item])); | ||
} | ||
@@ -57,3 +56,3 @@ get id() { | ||
id: this.id, | ||
events: [...new Set(ramda_1.default.pluck('type', [...this.eventHandlers.values()])).values()], | ||
events: [...new Set([...this.eventHandlers.values()].map(item => item.type)).values()], | ||
}); | ||
@@ -60,0 +59,0 @@ this.subscriber = await this.stream.subscribe(this.id, async (event) => { |
{ | ||
"name": "@arque/core", | ||
"version": "0.2.2", | ||
"version": "0.2.3", | ||
"description": "`arque` core library", | ||
@@ -34,3 +34,3 @@ "author": "ScaleForge", | ||
}, | ||
"gitHead": "47cbd0b684e2fa261e7ce7ac1c1bdc262c926406" | ||
"gitHead": "2334a096306998a2829d0affa23e73f3916fbc76" | ||
} |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
41674
711