import { Chain } from '../../../../sdk'; import { ChaintracksClientApi } from '../Api/ChaintracksClientApi'; import { BlockHeader } from '../Api/BlockHeaderApi'; import { LiveIngestorBase, LiveIngestorBaseOptions } from './LiveIngestorBase'; export interface LiveIngestorChaintracksSSEOptions extends LiveIngestorBaseOptions { chaintracks: ChaintracksClientApi; /** Maximum number of remote events retained for local processing. Default: 4096. */ maxQueuedHeaders?: number; } /** * Adapts a remote Chaintracks event stream, such as Arcade/go-chaintracks * `/chaintracks/v2/tip/stream`, into the local Chaintracks live-ingestor API. */ export declare class LiveIngestorChaintracksSSE extends LiveIngestorBase { private readonly options; static createLiveIngestorChaintracksSSEOptions(chain: Chain, chaintracks: ChaintracksClientApi): LiveIngestorChaintracksSSEOptions; private subscriptionId?; private stopped; private resolveStopped?; private readonly maxQueuedHeaders; private unsubscribePromise; constructor(options: LiveIngestorChaintracksSSEOptions); getHeaderByHash(hash: string): Promise; startListening(liveHeaders: BlockHeader[]): Promise; stopListening(): void; shutdown(): Promise; private queueUnsubscribe; private validateRemoteHeader; } //# sourceMappingURL=LiveIngestorChaintracksSSE.d.ts.map