import { Subject, Subscriber, Subscription } from "rxjs";
import { MqttMessage } from "./RxMQTT";
/** @internal
 * @description
 * This is a "copy" rxjs's ReplaySubject.
 * Stores messages for the same topic only once but in overall order.
 * Will emit the buffered messages upon subsicibe.
 * This mimics subscribing to multiple topics with wildcards for retained messages.
 *
 * Note: All messages will be treated as retained, no matter if they were sent as retained or not.
*/
export declare class MqttReplaySubject extends Subject<MqttMessage> {
    private _buffer;
    private _squence;
    constructor();
    next(value: MqttMessage): void;
    /** @internal */
    protected _subscribe(subscriber: Subscriber<MqttMessage>): Subscription;
    /** @internal */
    protected _throwIfClosed(): void;
    /** @internal */
    protected _checkFinalizedStatuses(subscriber: Subscriber<any>): void;
    /** @internal */
    protected _innerSubscribe(subscriber: Subscriber<any>): Subscription;
}