import { type Operation } from "effection";
import { type RuntimeServices } from "./runtime-services.js";
/** One parsed mailbox SSE payload with its ordered topic metadata. */
export interface MailboxSseMessage {
    idx: number;
    msg: Uint8Array;
    topic: string;
}
interface ReadMailboxSseBodyOptions {
    idleTimeoutMs?: number;
    maxDurationMs?: number;
    services?: RuntimeServices;
}
/**
 * Read one mailbox-style SSE response without waiting for remote EOF.
 *
 * KERIpy mailbox iterables keep the stream open for long-poll behavior, so
 * callers use an explicit read budget and idle timeout instead of waiting for
 * `response.text()` to resolve.
 */
export declare function readMailboxSseBody(response: Response, controller: AbortController, options?: ReadMailboxSseBodyOptions): Operation<string>;
/** Parse mailbox SSE text into `(topic, idx, payload)` tuples. */
export declare function parseMailboxSse(text: string): MailboxSseMessage[];
export {};
//# sourceMappingURL=mailbox-sse.d.ts.map