import { Effect } from 'effect';
import { type DecodedEntity } from '../../../core/index.js';
import { type AnyESchema } from '../../../eschema/index.js';
import { type WriteError } from '../../domain/sync-error/index.js';
import type { SyncStore } from '../../platform/sync-store/index.js';
type Delta<TItem> = {
    entities: DecodedEntity<TItem>[];
    position: string | null;
};
type SyncReplica<TItem> = {
    applyToSyncReplica: (entities: DecodedEntity<TItem>[]) => Effect.Effect<DecodedEntity<TItem>[], WriteError>;
    since: (position: string | null) => Effect.Effect<Delta<TItem>, WriteError>;
    /** Streams the rows after `position` one page at a time; resolves with the last position read. */
    eachPage: <E>(position: string | null, onPage: (page: Delta<TItem>) => Effect.Effect<void, E>) => Effect.Effect<{
        position: string | null;
        rows: number;
    }, WriteError | E>;
    get: (id: string) => Effect.Effect<DecodedEntity<TItem> | null, WriteError>;
};
export declare const makeSyncReplica: <S extends AnyESchema>(args: {
    store: SyncStore;
    schema: S;
    collectionName?: string;
    keyOf?: (value: S['Type']) => string | null;
}) => SyncReplica<S['Type']>;
export {};
//# sourceMappingURL=replica.d.ts.map