import { E as Events } from '../overrides-6Hxg764S.js';

type StreamOptions = {
    skipScope?: boolean;
    fanout: boolean;
};
type Stream<EventData> = {
    publish: (data: EventData) => Promise<boolean>;
    subscribe: (onMessage: (data: EventData) => Promise<void>) => void;
};
declare abstract class EventBus {
    abstract stream<Event extends Events[keyof Events]>(topic: Event['topic'], options?: Partial<StreamOptions>): Stream<Event['data']>;
}

export { EventBus, type Stream, type StreamOptions };