import { IEncodable, ITimeoutOptions } from '../util';
import { ISender, IReceiver } from '@consento/crypto';
import { INotifications, INotificationsTransport, INotificationsOptions, IConnection, INotificationProcessor, INotification, ISuccessNotification, INotificationError, ISubscribeOptions, IReceiveOptions } from './types';
export declare function isSuccess(input: INotification): input is ISuccessNotification;
export declare function isError(input: INotification): input is INotificationError;
export declare class EmptyTransport implements INotificationsTransport {
    subscribe(receivers: IReceiver[]): Promise<boolean[]>;
    unsubscribe(receivers: IReceiver[]): Promise<boolean[]>;
    reset(receivers: IReceiver[]): Promise<boolean[]>;
    send(): Promise<any[]>;
}
export declare class Notifications<TTransport extends INotificationsTransport> implements INotifications<TTransport> {
    _transport: TTransport;
    _receivers: {
        [receiverIdBase64: string]: IReceiver;
    };
    _reset: Promise<boolean[]> | undefined;
    processors: Set<INotificationProcessor>;
    constructor({ transport, error }: INotificationsOptions<TTransport>);
    get transport(): TTransport;
    reset(receivers: IReceiver[], opts?: ITimeoutOptions): Promise<boolean[]>;
    subscribe(receivers: IReceiver[], opts?: ISubscribeOptions): Promise<boolean[]>;
    unsubscribe(receivers: IReceiver[], opts?: ISubscribeOptions): Promise<boolean[]>;
    send(sender: ISender, message: IEncodable, opts?: ITimeoutOptions): Promise<string[]>;
    receive<T extends IEncodable>(receiver: IReceiver, opts?: IReceiveOptions<T>): Promise<{
        afterSubscribe: Promise<T>;
    }>;
    sendAndReceive<T extends IEncodable = IEncodable>(connection: IConnection, message: IEncodable, opts?: IReceiveOptions<T>): Promise<{
        afterSubscribe: Promise<T>;
    }>;
}