Interface ReplayLogService

interface ReplayLogService {
    consumeNext: (
        predicate: (event: ReplayLogEvent) => boolean,
    ) => Effect<ReplayLogEvent | undefined>;
    consumeNextResourceSnapshot: (
        params: {
            fieldPath: string;
            keyHash?: string;
            phase?: ResourceSnapshotPhase;
            resourceId: string;
        },
    ) => Effect<
        | {
            _tag: "ResourceSnapshot";
            concurrency?: string;
            fieldPath: string;
            instanceId?: string;
            keyHash?: string;
            moduleId?: string;
            phase: ResourceSnapshotPhase;
            resourceId: string;
            snapshot: unknown;
            timestamp: number;
        }
        | undefined,
    >;
    record: (event: ReplayLogEvent) => Effect<void>;
    resetCursor: Effect<void>;
    snapshot: Effect<readonly ReplayLogEvent[]>;
}