import { Cluster, Redis, RedisOptions } from 'ioredis';
import { Static, TSchema } from '@sidewinder/type';
import { Receiver } from '@sidewinder/channel';
/** Redis PubSub Receiver. This type uses broadcast semantics. */
export declare class PubSubRedisReceiver<T extends TSchema> implements Receiver<Static<T>> {
    #private;
    private readonly schema;
    readonly channel: string;
    private readonly redis;
    constructor(schema: T, channel: string, redis: Cluster | Redis);
    /** 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;
    /** Connects to Redis with the given parameters */
    static Create<T extends TSchema>(schema: T, topic: string, port?: number, host?: string, options?: RedisOptions): Promise<PubSubRedisReceiver<T>>;
    /** Connects to Redis with the given parameters */
    static Create<T extends TSchema>(schema: T, topic: string, host?: string, options?: RedisOptions): Promise<PubSubRedisReceiver<T>>;
    /** Connects to Redis with the given parameters */
    static Create<T extends TSchema>(schema: T, topic: string, options: RedisOptions): Promise<PubSubRedisReceiver<T>>;
}