import { EventStoreNodeConnection, ResolvedEvent, WriteResult } from 'node-eventstore-client';
import { Subject } from 'rxjs';
import { Config } from './contract/config';
import { Event } from './event';
export declare class EventStore {
    private readonly eventStoreSettings;
    client: EventStoreNodeConnection;
    subject$?: Subject<any>;
    isConnected: boolean;
    constructor(eventStoreSettings: Config);
    private connect;
    private attachHandlers;
    private createPayload;
    publish(event: Event): Promise<WriteResult | undefined>;
    publishAll(events: Event[]): Promise<WriteResult>;
    readStreamFromStart(streamId: string, resolveLinkTos?: boolean): AsyncGenerator<Event<any>, void, unknown>;
    convertEvent(r: ResolvedEvent): Event | undefined;
}