import { SubjectWrapper } from "../../models/subject";
export declare class SubjectWriter extends WritableStream<SubjectWrapper> {
    get closed(): boolean;
    private readonly subjectCount;
    private writerShouldResume?;
    private writerReachedTarget?;
    private target;
    private _closed;
    private resumePromise?;
    private pausePromise?;
    constructor(subjects: SubjectWrapper[]);
    closeStream(): Promise<void>;
    setTarget(newTarget: number): Promise<void>;
    /**
     * Unlocks the subject buffer WriteableStream and returns a promise that will
     * resolve when the writeable stream has reached its target or the end of the
     * data source.
     */
    private resumeWriter;
    /**
     * Pauses the writer and returns a promise that will will resolve when the
     * writer should resume fetching items.
     */
    private pauseWriter;
}