import { OnModuleDestroy, OnModuleInit } from '@nestjs/common';
import { EventBus, IEvent, IEventPublisher, IMessageSource } from '@nestjs/cqrs';
import { ExplorerService } from '@nestjs/cqrs/dist/services/explorer.service';
import * as Long from 'long';
import { EventStoreCatchUpSubscription, EventStorePersistentSubscription, EventStoreSubscription as EventStoreVolatileSubscription, ResolvedEvent } from 'node-eventstore-client';
import { Subject } from 'rxjs';
import { IEventStoreConnectConfig } from './contract/event-store-connect-config.interface';
import { EventStoreCatchupSubscription as ESCatchUpSubscription, EventStoreOptionConfig, EventStorePersistentSubscription as ESPersistentSubscription, EventStoreVolatileSubscription as ESVolatileSubscription, ExtendedCatchUpSubscription, ExtendedPersistentSubscription, ExtendedVolatileSubscription, IEventConstructors } from './contract/event-store-option.config';
export declare class EventStore implements IEventPublisher, OnModuleDestroy, OnModuleInit, IMessageSource {
    private readonly explorerService;
    private readonly eventsBus;
    private logger;
    private eventStore;
    private eventHandlers;
    private subject$;
    private readonly featureStream?;
    private readonly subscriptionsDelay?;
    private catchupSubscriptions;
    private catchupSubscriptionsCount;
    private persistentSubscriptions;
    private persistentSubscriptionsCount;
    private volatileSubscriptions;
    private volatileSubscriptionsCount;
    constructor(eventStore: any, configService: IEventStoreConnectConfig, esStreamConfig: EventStoreOptionConfig, explorerService: ExplorerService, eventsBus: EventBus);
    sleep(time: number): Promise<unknown>;
    publish(event: IEvent, stream?: string): Promise<void>;
    subscribeToPersistentSubscriptions(subscriptions: ESPersistentSubscription[]): Promise<void>;
    subscribeToCatchUpSubscriptions(subscriptions: ESCatchUpSubscription[]): Promise<void>;
    subscribeToVolatileSubscriptions(subscriptions: ESVolatileSubscription[]): Promise<void>;
    subscribeToCatchupSubscription(stream: string, resolveLinkTos?: boolean, lastCheckpoint?: number | Long | null): Promise<ExtendedCatchUpSubscription>;
    subscribeToVolatileSubscription(stream: string, resolveLinkTos?: boolean): Promise<ExtendedVolatileSubscription>;
    readonly allCatchUpSubscriptionsLive: boolean;
    readonly allVolatileSubscriptionsLive: boolean;
    readonly allPersistentSubscriptionsLive: boolean;
    subscribeToPersistentSubscription(stream: string, subscriptionName: string): Promise<ExtendedPersistentSubscription>;
    onEvent(_subscription: EventStorePersistentSubscription | EventStoreCatchUpSubscription | EventStoreVolatileSubscription, payload: ResolvedEvent): Promise<void>;
    onDropped(subscription: ExtendedPersistentSubscription | ExtendedCatchUpSubscription | ExtendedVolatileSubscription, _reason: string, error: Error): void;
    onLiveProcessingStarted(subscription: ExtendedCatchUpSubscription): void;
    readonly isLive: boolean;
    addEventHandlers(eventHandlers: IEventConstructors): void;
    onModuleInit(): any;
    onModuleDestroy(): any;
    bridgeEventsTo<T extends IEvent>(subject: Subject<T>): Promise<any>;
}