import { Effect, Layer, Scope, Stream } from 'effect';
import { EventStreamId, EventStoreError } from '@codeforbreakfast/eventsourcing-store';
export interface InMemorySubscriptionManagerService {
    readonly subscribeToStream: (streamId: EventStreamId) => Effect.Effect<Stream.Stream<string, never>, EventStoreError, Scope.Scope>;
    readonly unsubscribeFromStream: (streamId: EventStreamId) => Effect.Effect<void, EventStoreError, never>;
    readonly getSubscriptionMetrics: () => Effect.Effect<{
        readonly activeStreams: number;
        readonly totalSubscribers: number;
    }, never, never>;
}
declare const InMemorySubscriptionManager_base: import("effect/Context").TagClass<InMemorySubscriptionManager, "InMemorySubscriptionManager", InMemorySubscriptionManagerService> & Effect.Tag.Proxy<InMemorySubscriptionManager, InMemorySubscriptionManagerService> & {
    use: <X>(body: (_: InMemorySubscriptionManagerService) => X) => [X] extends [Effect.Effect<infer A, infer E, infer R>] ? Effect.Effect<A, E, InMemorySubscriptionManager | R> : [X] extends [PromiseLike<infer A_1>] ? Effect.Effect<A_1, import("effect/Cause").UnknownException, InMemorySubscriptionManager> : Effect.Effect<X, never, InMemorySubscriptionManager>;
};
export declare class InMemorySubscriptionManager extends InMemorySubscriptionManager_base {
}
export declare const makeInMemorySubscriptionManager: <T>() => Effect.Effect<InMemorySubscriptionManagerService, never, never>;
export declare const InMemorySubscriptionManagerLive: <T>() => Layer.Layer<InMemorySubscriptionManager, never, never>;
export {};
//# sourceMappingURL=subscriptionManager.d.ts.map