export type ISyncTopic<T> = {
    publish: (message: T) => void;
    subscribe: ISubscribeTopic<T>;
};
export type ISubscribeTopic<T> = (subscriber: ITopicSubscriber<T>) => IUnsubscribeTopic;
export type ITopicPublish<T> = (message: T) => Promise<void>;
export type ITopic<T> = {
    publish: ITopicPublish<T>;
    subscribe: ISubscribeTopic<T>;
};
export type ITopicSubscriber<T> = (message: T) => any;
export type IUnsubscribeTopic = () => void | any;
export declare function SyncTopic<T>(): ISyncTopic<T>;
export declare class TopicAggregateError extends Error {
    errors: Error[];
    constructor(errors: Error[], message?: string);
}
export declare function Topic<T>({ sequent, reversed, }?: {
    sequent?: boolean | undefined;
    reversed?: boolean | undefined;
}): ITopic<T>;
export declare function waitForMessage<T>(subscribe: ISubscribeTopic<T> | ITopic<T>, isAcceptable: (message: T) => boolean | Promise<boolean>): Promise<T>;