interface EventMessage {
    /**
     * Message payload
     */
    data?: string;
    /**
     * Message identifier, if set, client will send `Last-Event-ID: <id>` header on reconnect
     */
    id?: string;
    /**
     * Message type
     */
    event?: string;
    /**
     * Update client reconnect interval (how long will client wait before trying to reconnect).
     */
    retry?: number;
    /**
     * Message comment
     */
    comment?: string;
}
declare function transformAsyncIterable(source: AsyncIterable<EventMessage>): AsyncIterable<string>;
declare function serializeSSEEvent(chunk: EventMessage): string;
declare function sseReadableStream<T extends EventMessage>(iterator: AsyncGenerator<T>, abortSignal: AbortSignal): ReadableStream;

export { type EventMessage as E, sseReadableStream as a, serializeSSEEvent as s, transformAsyncIterable as t };