import { Effect, Layer, Stream } from 'effect';
import { EventStreamId, EventStreamPosition, EventStoreError, type StreamEvent } from '@codeforbreakfast/eventsourcing-store';
/**
 * SubscriptionManager service for managing subscriptions to event streams
 */
export interface SubscriptionManagerService {
    /**
     * Subscribe to a specific event stream and return a Stream of events
     */
    readonly subscribeToStream: (streamId: EventStreamId) => Effect.Effect<Stream.Stream<string, never>, EventStoreError, never>;
    /**
     * Unsubscribe from a specific event stream
     */
    readonly unsubscribeFromStream: (streamId: EventStreamId) => Effect.Effect<void, EventStoreError, never>;
    /**
     * Publish an event to all subscribers of a stream
     */
    readonly publishEvent: (streamId: EventStreamId, event: string) => Effect.Effect<void, EventStoreError, never>;
    /**
     * Subscribe to all events from all streams
     */
    readonly subscribeToAllEvents: () => Effect.Effect<Stream.Stream<StreamEvent<string>, never>, EventStoreError, never>;
    /**
     * Publish an event to all-events subscribers
     */
    readonly publishToAllEvents: (position: EventStreamPosition, event: string) => Effect.Effect<void, EventStoreError, never>;
}
declare const SubscriptionManager_base: import("effect/Context").TagClass<SubscriptionManager, "SubscriptionManager", SubscriptionManagerService> & Effect.Tag.Proxy<SubscriptionManager, SubscriptionManagerService> & {
    use: <X>(body: (_: SubscriptionManagerService) => X) => [X] extends [Effect.Effect<infer A, infer E, infer R>] ? Effect.Effect<A, E, R | SubscriptionManager> : [X] extends [PromiseLike<infer A_1>] ? Effect.Effect<A_1, import("effect/Cause").UnknownException, SubscriptionManager> : Effect.Effect<X, never, SubscriptionManager>;
};
export declare class SubscriptionManager extends SubscriptionManager_base {
}
/**
 * Implementation of SubscriptionManager service
 */
export declare const SubscriptionManagerLive: Layer.Layer<SubscriptionManager, never, never>;
export {};
//# sourceMappingURL=subscriptionManager.d.ts.map