import { AggregateId } from '../core/api/tactical/aggregate/aggregate-id';
import { AggregateEvent } from '../core/api/tactical/aggregate/aggregate-event';
import { DomainEvent } from '../core/api/event/domain-event';
import { HermesObservable } from '../common/stream/core/observable/hermes.observable';
import { Optional } from '../common/optional';
export declare function assertDomainEvents<I extends AggregateId>(actualEvents: ReadonlyArray<DomainEvent<I>>, expectedEvents: Array<DomainEvent<I>>): void;
export declare function assertAggregateEvents<T extends AggregateId>(actualEvents: ReadonlyArray<AggregateEvent<T>>, expectedEvents: Array<AggregateEvent<T>>): void;
export declare function testEventRepositoryIsEmptyOnStart<T>(createStream: () => HermesObservable<T>, desc: string): void;
export declare function onDefaultValuesWarehouseTest<T>(createStream: () => HermesObservable<T>, defaultValue: T, desc: string): void;
export declare function onceDefaultValuesWarehouseTest<T>(createStream: () => HermesObservable<T>, defaultValue: T, desc: string): void;
export declare function onWarehouseEmpty<T>(createStream: () => HermesObservable<T>, desc: string): void;
export declare function findDefaultValuesWarehouseTest<T>(createValue: () => Optional<T>, defaultValue: T, desc: string): void;
export declare function commandInterceptedByHandlerTest(dispatch: () => void, handlerType: any): void;
export declare function commandPublishEventTest(dispatch: () => void, eventType: any): void;
export declare function commandTriggersHandlerAndPublishEventTest(dispatch: () => void, handlerType: any, eventType: any): void;