import * as Component from './Component';
import { Query } from './Query';
import { Request } from './Request';
import { Reply } from './Reply';
import { Typer } from 'cqes-type';
export declare type queryHandler = (query: Query) => Promise<Reply>;
export declare type requestHandler = (requesy: Request) => Promise<Reply>;
export interface QueryTypes {
    [name: string]: Typer;
}
export interface RequestTypes {
    [name: string]: Typer;
}
export interface ReplyTypes {
    [name: string]: Typer;
}
export interface Subscription {
    abort: () => Promise<void>;
}
export interface Transport {
    start: () => Promise<void>;
    stop: () => Promise<void>;
    serveQuery: (handler: queryHandler) => Promise<Subscription>;
    query: queryHandler;
    serveRequest: (handler: requestHandler) => Promise<Subscription>;
    request: requestHandler;
}
export interface props extends Component.props {
    transport: string;
    mode: 'client' | 'server';
    view?: string;
    queries?: QueryTypes;
    requests?: RequestTypes;
}
export declare class RpcBus extends Component.Component {
    protected transport: Transport;
    protected queries: QueryTypes;
    protected requests: RequestTypes;
    protected view: string;
    constructor(props: props);
    start(): Promise<void>;
    stop(): Promise<void>;
    serveQuery(queryHandler: queryHandler): Promise<Subscription>;
    query(method: string, data: any, meta?: any): Promise<Reply>;
    serveRequest(requestHandler: requestHandler): Promise<Subscription>;
    request(method: string, data: any, meta?: any): Promise<Reply>;
}