import "../domain/ports/common.mjs";
import { Connection } from "mongoose";
import { DomainEvent, EventTransport } from "@classytic/primitives/events";
//#region src/repositories/run-unit.d.ts
/**
 * Public escape hatch for advanced cross-engine composition. Drains an
 * event queue (typically the one a host attached under `[PENDING_EVENTS]`)
 * through a transport, swallowing per-event errors. Failures are logged
 * via the optional logger; durable delivery is the outbox's job.
 *
 * Most hosts should use `engine.withTransaction(ctx, fn)` instead — it
 * handles allocation, transaction wrap, and post-commit flush in one call.
 */
declare function flushPending(eventTransport: EventTransport | undefined, events: DomainEvent[], logger?: {
  error(message: string, ...args: unknown[]): void;
}): Promise<void>;
//#endregion
export { flushPending };