/** * flashQ Events - Real-time event subscriptions. * * @example * ```typescript * import { EventSubscriber } from 'flashq'; * * const events = new EventSubscriber({ host: 'localhost', httpPort: 6790 }); * events.on('completed', (event) => console.log(`Job ${event.jobId} completed`)); * await events.connect(); * ``` */ export * from './types'; export { EventSubscriber } from './subscriber'; import { EventSubscriber } from './subscriber'; import type { EventSubscriberOptions, JobEvent } from './types'; /** Create an SSE event subscriber */ export declare function createEventSubscriber(options?: EventSubscriberOptions): EventSubscriber; /** Create a WebSocket event subscriber */ export declare function createWebSocketSubscriber(options?: EventSubscriberOptions): EventSubscriber; /** Subscribe to events with a simple callback */ export declare function subscribeToEvents(options: EventSubscriberOptions, callback: (event: JobEvent) => void): Promise<() => void>; export default EventSubscriber; //# sourceMappingURL=index.d.ts.map