import type { JsMsg } from "./jsmsg";
import type { ConsumerConfig, ConsumerInfo } from "./jsapi_types";
import type { ConsumerNotification } from "./types";
import type { ConsumerAPI, ConsumerCallbackFn, ConsumerMessages, PushConsumer, PushConsumerOptions } from "./types";
import type { ConsumerAPIImpl } from "./jsmconsumer_api";
import { IdleHeartbeatMonitor, QueuedIteratorImpl } from "@nats-io/nats-core/internal";
import type { CallbackFn, Delay, QueuedIterator, Status, Subscription } from "@nats-io/nats-core/internal";
export declare class PushConsumerMessagesImpl extends QueuedIteratorImpl<JsMsg> implements ConsumerMessages {
    consumer: PushConsumerImpl;
    sub: Subscription;
    monitor: IdleHeartbeatMonitor | null;
    listeners: QueuedIterator<ConsumerNotification>[];
    abortOnMissingResource: boolean;
    callback: ConsumerCallbackFn | null;
    ordered: boolean;
    cursor: {
        stream_seq: number;
        deliver_seq: number;
    };
    namePrefix: string | null;
    deliverPrefix: string | null;
    serial: number;
    createFails: number;
    statusIterator: QueuedIteratorImpl<Status>;
    cancelables: Delay[];
    constructor(c: PushConsumerImpl, userOptions?: Partial<PushConsumerOptions>, internalOptions?: Partial<PushConsumerInternalOptions>);
    reset(): void;
    getConsumerOpts(): ConsumerConfig;
    closed(): Promise<void | Error>;
    close(): Promise<void | Error>;
    stop(err?: Error): void;
    _push(r: JsMsg | CallbackFn): void;
    status(): AsyncIterable<ConsumerNotification>;
    start(): void;
    notify(n: ConsumerNotification): void;
}
export type PushConsumerInternalOptions = PushConsumerOptions & {
    bound: boolean;
    ordered: boolean;
    name_prefix: string;
    deliver_prefix: string;
};
export declare class PushConsumerImpl implements PushConsumer {
    api: ConsumerAPIImpl;
    _info: ConsumerInfo;
    stream: string;
    name: string;
    bound: boolean;
    ordered: boolean;
    started: boolean;
    serial: number;
    opts: Partial<PushConsumerInternalOptions>;
    constructor(api: ConsumerAPI, info: ConsumerInfo, opts?: Partial<PushConsumerInternalOptions>);
    consume(userOptions?: Partial<PushConsumerOptions>): Promise<ConsumerMessages>;
    delete(): Promise<boolean>;
    info(cached?: boolean): Promise<ConsumerInfo>;
    isPullConsumer(): boolean;
    isPushConsumer(): boolean;
}