import { Monitor } from '../Monitor'; import { WalletMonitorTask } from './WalletMonitorTask'; import { TableProvenTxReq } from '../../storage/schema/tables/TableProvenTxReq'; export declare class TaskSendWaiting extends WalletMonitorTask { triggerMsecs: number; agedMsecs: number; sendingMsecs: number; triggerQuickMsecs: number; chunkLimit: number; static readonly taskName = "SendWaiting"; lastSendingRunMsecsSinceEpoch: number | undefined; includeSending: boolean; triggerNextMsecs: number; /** * @param monitor Wallet monitor owning this task. * @param triggerMsecs Normal interval between SendWaiting runs when no backlog remains. * @param agedMsecs Minimum age a request must reach before this task will attempt to send it. * @param sendingMsecs Minimum interval before stale `sending` requests are included again. * @param triggerQuickMsecs Follow-up interval used when a full chunk was consumed and more work may remain. * @param chunkLimit Maximum number of waiting requests to fetch and inspect in a single run. */ constructor(monitor: Monitor, triggerMsecs?: number, agedMsecs?: number, sendingMsecs?: number, triggerQuickMsecs?: number, chunkLimit?: number); trigger(nowMsecsSinceEpoch: number): { run: boolean; }; runTask(): Promise; private expandBatches; private filterAgedReqs; /** * Process an array of 'unsent' status table.ProvenTxReq * * Send rawTx to transaction processor(s), requesting proof callbacks when possible. * * Set status 'invalid' if req is invalid. * * Set status to 'callback' on successful network submission with callback service. * * Set status to 'unmined' on successful network submission without callback service. * * Add mapi responses to database table if received. * * Increments attempts if sending was attempted. * * @param reqApis */ processUnsent(reqApis: TableProvenTxReq[], indent?: number): Promise; } //# sourceMappingURL=TaskSendWaiting.d.ts.map