import type { BinaryNode } from '../WABinary/index.js'; export type MessageType = 'message' | 'call' | 'receipt' | 'notification'; export type OfflineNodeProcessorDeps = { isWsOpen: () => boolean; onUnexpectedError: (error: Error, msg: string) => void; yieldToEventLoop: () => Promise; }; /** * Creates a processor for offline stanza nodes that: * - Queues nodes for sequential processing * - Yields to the event loop periodically to avoid blocking * - Catches handler errors to prevent the processing loop from crashing */ export declare function makeOfflineNodeProcessor(nodeProcessorMap: Map Promise>, deps: OfflineNodeProcessorDeps, batchSize?: number): { enqueue: (type: MessageType, node: BinaryNode) => void; }; //# sourceMappingURL=offline-node-processor.d.ts.map