import { TSchema, Static } from '@sidewinder/type';
import { Receiver } from '@sidewinder/channel';
/** In-Memory Redis PubSub Receiver. This type operates on memory queue and can be used in absense of Redis infrastructure */
export declare class PubSubMemoryReceiver<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 PubSubMemoryReceiver with the given parameters */
    static Create<T extends TSchema>(schema: T, channel: string): PubSubMemoryReceiver<T>;
}