import { Stream, type ConsumeOptions } from "./Stream.class.js";
import type { Entry } from "../../types/index.js";
/**
 *
 * @description Handling intrapersonal communication through a redis stream
 */
export declare class Intrapersonal extends Stream {
    [Symbol.asyncIterator](): AsyncGenerator<Entry[], void, unknown>;
    consume(options?: ConsumeOptions): Promise<Entry[]>;
    cleanStream(): Promise<Entry[] | null>;
}
//# sourceMappingURL=Intrapersonal.class.d.ts.map