import { Effect, Layer, Option } from 'effect';
import { EventStreamPosition } from '@codeforbreakfast/eventsourcing-store';
declare const EventStreamTracker_base: import("effect/Context").TagClass<EventStreamTracker, "EventStreamTracker", Readonly<{
    /**
     * Process an event, ensuring proper ordering and deduplication
     * Returns Some(event) if the event should be processed, None if it's a duplicate or out of order
     */
    readonly processEvent: <T>(position: EventStreamPosition, event: T) => Effect.Effect<Option.Option<T>, never, never>;
}>> & Effect.Tag.Proxy<EventStreamTracker, Readonly<{
    /**
     * Process an event, ensuring proper ordering and deduplication
     * Returns Some(event) if the event should be processed, None if it's a duplicate or out of order
     */
    readonly processEvent: <T>(position: EventStreamPosition, event: T) => Effect.Effect<Option.Option<T>, never, never>;
}>> & {
    use: <X>(body: (_: Readonly<{
        /**
         * Process an event, ensuring proper ordering and deduplication
         * Returns Some(event) if the event should be processed, None if it's a duplicate or out of order
         */
        readonly processEvent: <T>(position: EventStreamPosition, event: T) => Effect.Effect<Option.Option<T>, never, never>;
    }>) => X) => [X] extends [Effect.Effect<infer A, infer E, infer R>] ? Effect.Effect<A, E, R | EventStreamTracker> : [X] extends [PromiseLike<infer A_1>] ? Effect.Effect<A_1, import("effect/Cause").UnknownException, EventStreamTracker> : Effect.Effect<X, never, EventStreamTracker>;
};
/**
 * EventStreamTracker service for tracking event ordering and deduplication
 *
 * Note: The processEvent method has a generic type parameter, which means
 * it cannot use Effect service accessors. This is by design and doesn't
 * affect functionality - the service is accessed via yield* EventStreamTracker.
 */
export declare class EventStreamTracker extends EventStreamTracker_base {
}
/**
 * Implementation of EventStreamTracker service
 */
export declare const EventStreamTrackerLive: () => Layer.Layer<EventStreamTracker, never, never>;
export {};
//# sourceMappingURL=eventStreamTracker.d.ts.map