import { Principal } from '@dfinity/principal'; import { _SERVICE as AggregatorAPI, GlobalId, TxInput } from '../../candid/aggregator'; import { Delegate } from './delegate'; import { QueryRetryInterceptorErrorCallback } from './call-interceptors'; export type TxAggStatus = { status: 'pending'; } | { status: 'queued'; queueNumber: bigint; } | { status: 'other'; lastLedgerTimestamp: bigint; }; export declare class AggregatorDelegate extends Delegate { protected readonly _canisterPrincipal: Principal | string; constructor(_canisterPrincipal: Principal | string, network: 'ic' | 'local'); submitAndExecute(txs: TxInput[]): Promise; singleSubmitAndExecute(tx: TxInput): Promise; private castTxStatusResponse; txStatus(gids: GlobalId[], retryErrorCallback?: QueryRetryInterceptorErrorCallback): Promise; singleTxStatus(id: GlobalId, retryErrorCallback?: QueryRetryInterceptorErrorCallback): Promise; timestampedSingleTxStatus(id: GlobalId, retryErrorCallback?: QueryRetryInterceptorErrorCallback): Promise<[TxAggStatus, number]>; streamStatus(): Promise<{ id: bigint; sent: bigint; received: bigint; length: bigint; }[]>; }