{"version":3,"sources":["../../../src/events/base.ts","/home/runner/work/equipped/equipped/dist/cjs/events/base.cjs"],"names":[],"mappings":"AAIO,+EAAe,SAAS;AAQ/B;ACVA;AACE;AACF,4BAAC","file":"/home/runner/work/equipped/equipped/dist/cjs/events/base.cjs","sourcesContent":["import type { Events } from '../types'\n\nexport type StreamOptions = { skipScope?: boolean; fanout: boolean }\n\nexport abstract class EventBus {\n\tabstract createStream<Event extends Events[keyof Events]>(\n\t\ttopic: Event['topic'],\n\t\toptions?: Partial<StreamOptions>,\n\t): {\n\t\tpublish: (data: Event['data']) => Promise<boolean>\n\t\tsubscribe: (onMessage: (data: Event['data']) => Promise<void>) => void\n\t}\n}\n",null]}