import { Static, TSchema } from '@sidewinder/type';
import { SyncSender } from '@sidewinder/channel';
export declare class MemorySenderError extends Error {
    constructor(message: string);
}
/** In-Memory Redis Sender. This type operates on memory queue and can be used in absense of Redis infrastructure */
export declare class MemorySender<T extends TSchema> implements SyncSender<Static<T>> {
    #private;
    private readonly schema;
    private readonly channel;
    constructor(schema: T, channel: string);
    /** Sends a value to this sender */
    send(value: Static<T, []>): Promise<void>;
    /** Sends an error to this sender and closes. Note that redis channels do not transmit the error. */
    error(error: Error): Promise<void>;
    /** Ends this sender and closes */
    end(): Promise<void>;
    /** Creates a MemorySender with the given parameters */
    static Create<T extends TSchema>(schema: T, channel: string): MemorySender<T>;
}