* Stores an event with a generated event ID * Implements EventStore.storeEvent
(streamId: string, message: JSONRPCMessage)
| 36 | * Implements EventStore.storeEvent |
| 37 | */ |
| 38 | async storeEvent(streamId: string, message: JSONRPCMessage): Promise<string> { |
| 39 | const eventId = this.generateEventId(streamId); |
| 40 | this.events.set(eventId, { streamId, message }); |
| 41 | return eventId; |
| 42 | } |
| 43 | |
| 44 | /** |
| 45 | * Replays events that occurred after a specific event ID |
nothing calls this directly
no test coverage detected