import { NatsConnection } from "@nats-io/nats-core";
import { Service } from "@nats-io/services";
import * as events from "@weegigs/events-core";
import { Signal } from "@weegigs/events-common";
import { WorkerPool } from "./worker-pool";
export declare class NatsService<S extends events.State> {
    private readonly nats;
    private readonly service;
    private readonly pool;
    private readonly shutdownSignal;
    static create<R extends events.Environment, S extends events.State>(description: events.ServiceDescription<R, S>): {
        connect(connection: NatsConnection, store: events.EventStore, environment: Omit<R, "publish">): Promise<NatsService<S>>;
    };
    static wrap<S extends events.State>(service: events.Service<S>): {
        connect(connection: NatsConnection): Promise<NatsService<S>>;
    };
    private readonly iteratorProcessors;
    constructor(nats: Service, service: events.Service<S>, pool: WorkerPool<events.Entity<S>>, shutdownSignal: Signal<null>);
    private registerCommandEndpoint;
    private processCommandIterator;
    private handleCommandMessage;
    private handleError;
    private getErrorCode;
    start(): Promise<void>;
    shutdown(): Promise<void>;
}
//# sourceMappingURL=nats-service.d.ts.map