import { Effect } from 'effect'; import type { Connectivity } from '../../domain/connectivity/index.js'; import type { WriteError } from '../../domain/sync-error/index.js'; import type { EntryStore, OutboxEntry, OutboxOutcome } from '../entries/index.js'; import type { Handlers } from '../handlers/index.js'; export type DrainerDeps = { readonly entries: EntryStore; readonly handlers: Pick; readonly connectivity: Connectivity; readonly awaitSignal: Effect.Effect; readonly signal: () => void; readonly ring: (id: string, outcome: OutboxOutcome) => Effect.Effect; readonly onRequestFailed?: (entries: ReadonlyArray, cause: unknown) => Effect.Effect; }; export declare const runDrainer: (deps: DrainerDeps) => Effect.Effect; //# sourceMappingURL=drainer.d.ts.map