import { Subject, type Subscription, type Subscriber } from 'rxjs';
export declare class BufferSubject<T> extends Subject<T> {
    readonly bufferSize: number;
    private buffer;
    private isBuffering;
    constructor(bufferSize: number);
    protected _subscribe(subscriber: Subscriber<T>): Subscription;
    next(value: T): void;
    flush(): void;
}