import { ConstructorOf, SubjectMessage, SubjectMessageHandler, SubjectMessageOptions } from './messages';
import { MeshBackend } from './mesh';
export declare const PSEUDO_MESSAGE_NS: string;
export declare const PSEUDO_MESSAGE_BEFORE: string;
export declare const PSEUDO_MESSAGE_AFTER: string;
export interface Subject {
    before<T>(handler: SubjectMessageHandler<T>): Subject;
    on<T>(name: (string | ConstructorOf<T>), handler: SubjectMessageHandler<T>): Subject;
    after<T>(handler: SubjectMessageHandler<T>): Subject;
    broadcast<T>(message: SubjectMessage, options?: SubjectMessageOptions): Promise<T[]>;
    send<T>(message: any, options?: SubjectMessageOptions): Promise<T>;
    send<T>(partitionKey: string, message: SubjectMessage, options?: SubjectMessageOptions): Promise<T>;
    awaitRegistration(): Promise<void>;
    unbind(): Promise<void>;
}
export declare class SubjectBase implements Subject {
    private readonly subjectName;
    private readonly meshPrivate;
    constructor(subjectName: string, meshPrivate: MeshBackend);
    before<T>(handler: SubjectMessageHandler<T>): Subject;
    on<T>(name: string | ConstructorOf<T>, handler: SubjectMessageHandler<T>): Subject;
    after<T>(handler: SubjectMessageHandler<T>): Subject;
    broadcast<T>(message: SubjectMessage, options?: SubjectMessageOptions): Promise<T[]>;
    send<T>(message: SubjectMessage, options?: SubjectMessageOptions): Promise<T>;
    send<T>(partitionKey: string, message: SubjectMessage, options?: SubjectMessageOptions): Promise<T>;
    awaitRegistration(): Promise<void>;
    unbind(): Promise<void>;
}