import type { ResolveConflict, SyncStore, WasSyncPort } from './types.js'; /** * Pushes every dirty row for one feed, sequentially (bounds sockets/CPU, and * keeps conflict reconciliation deterministic). Honors `signal` between rows. * A non-conflict error from any row propagates so the engine aborts the cycle * and backs off; already-pushed rows in the batch stay settled. * * @param options {object} * @param options.port {WasSyncPort} * @param options.store {SyncStore} * @param [options.resolveConflict] {ResolveConflict} mutable-collection policy * @param [options.signal] {AbortSignal} * @returns {Promise<{ pushed: number; conflictsResolved: number }>} dirty rows * processed this cycle, and how many invoked the LWW resolver (a positive * count means the caller should rerun so a local-wins re-push settles) */ export declare function runPush({ port, store, resolveConflict, signal }: { port: WasSyncPort; store: SyncStore; resolveConflict?: ResolveConflict; signal?: AbortSignal; }): Promise<{ pushed: number; conflictsResolved: number; }>; //# sourceMappingURL=push.d.ts.map