Added support for subscribing to stream for ESDB Consumer

event-driven-io · Feb 13, 2025 · 68542af · 68542af
1 parent e6ded8b
commit 68542af
Show file tree

Hide file tree

Showing 6 changed files with 469 additions and 424 deletions.
diff --git a/src/packages/emmett-esdb/src/eventStore/eventstoreDBEventStore.ts b/src/packages/emmett-esdb/src/eventStore/eventstoreDBEventStore.ts
@@ -24,7 +24,6 @@ import {
   StreamNotFoundError,
   WrongExpectedVersionError,
   jsonEvent,
-  type AllStreamJSONRecordedEvent,
   type AppendExpectedRevision,
   type ReadStreamOptions as ESDBReadStreamOptions,
   type JSONRecordedEvent,
@@ -208,7 +207,7 @@ export const getEventStoreDBEventStore = (
 };
 
 export const mapFromESDBEvent = <EventType extends Event = Event>(
-  event: JSONRecordedEvent<EventType> | AllStreamJSONRecordedEvent<EventType>,
+  event: JSONRecordedEvent<EventType>,
 ): ReadEvent<EventType, EventStoreDBReadEventMetadata> => {
   return <ReadEvent<EventType, EventStoreDBReadEventMetadata>>{
     type: event.type,