import * as Component from './Component';
import { Event as E } from './Event';
import { Typer } from 'cqes-type';
export declare type eventHandler<T = void> = (event: E) => Promise<T>;
export declare enum EventHandling {
    Ignored = 0,
    Handled = 1
}
export interface Transport {
    start: () => Promise<void>;
    save: (events: Array<E>) => Promise<void>;
    readAllFrom: (position: number, handler: eventHandler) => Promise<void>;
    readCategoryFrom: (category: string, position: number, handler: eventHandler) => Promise<void>;
    readStreamFrom: (category: string, id: string, number: number, handler: eventHandler) => Promise<void>;
    readStreamLast: (category: string, id: string, count: number) => Promise<Array<E>>;
    subscribe: (category: string, handler: eventHandler) => Promise<Subscription>;
    psubscribe: (name: string, category: string, handler: eventHandler<EventHandling>) => Promise<Subscription>;
    stop: () => Promise<void>;
}
export interface Subscription {
    abort: () => Promise<void>;
}
export interface EventTypes {
    [name: string]: Typer;
}
export interface props extends Component.props {
    transport: string;
    originContext?: string;
    category: string;
    events: EventTypes;
}
export declare class EventBus extends Component.Component {
    protected transport: Transport;
    protected events: EventTypes;
    readonly category: string;
    constructor(props: props);
    start(): Promise<void>;
    subscribe(handler: eventHandler): Promise<Subscription>;
    psubscribe(name: string, handler: eventHandler<EventHandling>): Promise<Subscription>;
    emit(category: string, streamId: string, number: number, name: string, data: any, meta?: any): Promise<void>;
    emitEvents(events: Array<E>): Promise<void>;
    readAllFrom(position: number, handler: eventHandler): Promise<void>;
    readCategoryFrom(category: string, position: number, handler: eventHandler): Promise<void>;
    readStreamFrom(category: string, streamId: string, number: number, handler: eventHandler): Promise<void>;
    readStreamLast(category: string, streamId: string, count: number): Promise<E<any, any>[]>;
    typeEvent(event: E): E<any, any>;
    stop(): Promise<void>;
}