import { Effect, Scope, Stream } from 'effect';
import { EventStreamPosition, EventStore, EventStoreError } from '@codeforbreakfast/eventsourcing-store';
import { type InMemoryStore } from './InMemoryStore';
export interface SubscribableEventStore<T> extends EventStore<T> {
    readonly subscribeToStream: (streamId: EventStreamPosition['streamId']) => Effect.Effect<Stream.Stream<T, never>, EventStoreError, Scope.Scope>;
}
export declare const makeInMemoryEventStore: <T>(store: InMemoryStore<T>) => Effect.Effect<EventStore<T>, never, never>;
export declare const makeSubscribableInMemoryEventStore: <T>(store: InMemoryStore<T>) => Effect.Effect<SubscribableEventStore<T>, never, never>;
//# sourceMappingURL=inMemoryEventStore.d.ts.map