事件tore API

依据

• https://github.com/tim-group/tg-eventstore 页面存档备份,存于互联网档案馆 互联网档案馆 (贾瓦)
• https://github.com/araqnid/eventstore 页面存档备份,存于互联网档案馆 (科特林语)

使用量

读取流 :

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})))
  )
}

读取整个商店 :

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)
    )
}))

以 Pretier 格式化代码

建议您使用 prettier 用于格式化,以便我们有一个一致的代码样式.

如果您正在使用IntelliJ,请安装 Pretier 插件 。 您可以在正常运行格式时配置它以运行( 见 Languages & Frameworks > Javascript > Prettier 并检查“ 运行“ 格式化代码” 动作”