3.0.0 • Published 3 months ago
@acuris/eventstore-api v3.0.0
Eventstore API
Based on
Usage
Reading a stream:
async function listTransactionHistory(transactionId: string, eventSource: EventSource): Promise<{timestamp: Date, data: Transaction}> {
return lastValueFrom(
eventSource.streamReader.readStreamForwards({category: "transaction", id: transactionId})
.pipe(toArray(), map(re => ({timestamp: re.event.timestamp, data: re.event.data as Transaction})))
)
}
Reading entire store:
return new Promise(((resolve, reject) => {
let lastPosition = position
eventSource.storeReader.readAll(position).subscribe(
re => {
ingestTransaction(re.event.data as Transaction)
lastPosition = re.position
},
err => reject("Failed to read all transactions since " + lastPosition + ": " + err),
() => resolve(lastPosition)
)
}))
Code Formatting with Prettier
Recommend you use prettier
for formatting so that we have a consistent code style.
If you are using IntelliJ then install the Prettier plugin. You can config it to run when you normally run format (see
Languages & Frameworks > Javascript > Prettier
and check "Run on 'Reformat Code' action")
3.0.0
3 months ago
2.3.4
2 years ago
2.3.2
2 years ago
2.3.3
2 years ago
2.3.0
2 years ago
2.3.1
2 years ago
2.2.0
2 years ago
2.1.10
2 years ago
2.0.1
3 years ago
1.3.8
3 years ago
2.0.0
3 years ago
1.3.7
3 years ago
1.3.6
3 years ago
1.3.5
3 years ago
1.3.4
3 years ago
1.3.3
3 years ago
1.3.2
3 years ago
1.3.1
3 years ago
1.3.0
3 years ago
1.2.5
3 years ago
1.2.4
4 years ago
1.2.3
4 years ago
1.2.2
4 years ago
1.2.1
4 years ago
1.1.6
4 years ago
1.1.5
4 years ago
1.1.4
4 years ago
1.1.3
4 years ago
1.1.2
4 years ago
1.1.1
4 years ago
1.1.0
4 years ago