{"version":3,"sources":["../../../src/events/index.ts","../../../src/events/adapters/base.ts"],"sourcesContent":["export * from './adapters/base'\n","import type { Events } from '../../types'\n\nexport type StreamOptions = { skipScope?: boolean; fanout: boolean }\n\nexport type Stream<EventData> = {\n\tpublish: (data: EventData) => Promise<boolean>\n\tsubscribe: (onMessage: (data: EventData) => Promise<void>) => void\n}\n\nexport abstract class EventBus {\n\tabstract stream<Event extends Events[keyof Events]>(topic: Event['topic'], options?: Partial<StreamOptions>): Stream<Event['data']>\n}\n"],"mappings":"yaAAA,IAAAA,EAAA,GAAAC,EAAAD,EAAA,cAAAE,IAAA,eAAAC,EAAAH,GCSO,IAAeI,EAAf,KAAwB,CAE/B","names":["events_exports","__export","EventBus","__toCommonJS","EventBus"]}