import { Static, TSchema } from '@sidewinder/type';
import { Receiver } from '@sidewinder/channel';
export declare class MemoryReceiverError extends Error {
    constructor(message: string);
}
/** In-Memory Redis Receiver. This type operates on memory queue and can be used in absense of Redis infrastructure */
export declare class MemoryReceiver<T extends TSchema> implements Receiver<Static<T>> {
    #private;
    private readonly schema;
    private readonly channel;
    constructor(schema: T, channel: string);
    /** Async iterator for this Receiver */
    [Symbol.asyncIterator](): AsyncGenerator<Awaited<Awaited<Static<T, []>> & undefined> | Awaited<Awaited<Static<T, []>> & {}>, void, unknown>;
    /** Reads the next value from this Receiver */
    next(): Promise<Static<T, []> | null>;
    /** Closes this receiver */
    close(): void;
    /** Creates a MemoryReceiver with the given parameters */
    static Create<T extends TSchema>(schema: T, channel: string): MemoryReceiver<T>;
}