@acuris/eventstore-api
Advanced tools
Comparing version 2.3.3 to 2.3.4
@@ -16,7 +16,7 @@ "use strict"; | ||
readAllForwards(positionExclusive = this.storeReader.emptyStorePosition) { | ||
return this.storeReader.readAllForwards().pipe((0, rxjs_1.filter)((re) => this.categories.has(re.event.streamId.category))); | ||
return this.storeReader.readAllForwards(positionExclusive).pipe((0, rxjs_1.filter)((re) => this.categories.has(re.event.streamId.category))); | ||
} | ||
readAllHeadersForwards(positionExclusive = this.storeReader.emptyStorePosition) { | ||
return this.storeReader | ||
.readAllHeadersForwards() | ||
.readAllHeadersForwards(positionExclusive) | ||
.pipe((0, rxjs_1.filter)((reh) => this.categories.has(reh.event.streamId.category))); | ||
@@ -23,0 +23,0 @@ } |
@@ -14,7 +14,7 @@ import { filter } from 'rxjs'; | ||
readAllForwards(positionExclusive = this.storeReader.emptyStorePosition) { | ||
return this.storeReader.readAllForwards().pipe(filter((re) => this.categories.has(re.event.streamId.category))); | ||
return this.storeReader.readAllForwards(positionExclusive).pipe(filter((re) => this.categories.has(re.event.streamId.category))); | ||
} | ||
readAllHeadersForwards(positionExclusive = this.storeReader.emptyStorePosition) { | ||
return this.storeReader | ||
.readAllHeadersForwards() | ||
.readAllHeadersForwards(positionExclusive) | ||
.pipe(filter((reh) => this.categories.has(reh.event.streamId.category))); | ||
@@ -21,0 +21,0 @@ } |
{ | ||
"name": "@acuris/eventstore-api", | ||
"private": false, | ||
"version": "2.3.3", | ||
"version": "2.3.4", | ||
"description": "API for accessing event stores", | ||
@@ -6,0 +6,0 @@ "keywords": [ |
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
31542