export declare const SUBSCRIPTION_QUEUE_MAX_BYTES: number;
export type QueueValue<T> = {
    readonly done: false;
    readonly value: T;
} | {
    readonly done: true;
};
export declare class BoundedQueue<T> {
    #private;
    get retainedCount(): number;
    push(value: T, bytes: number): 'buffered' | 'delivered' | 'overflow' | 'closed';
    recv(): Promise<QueueValue<T>>;
    endRetainingBuffer(): void;
    closeAndDiscard(): void;
}