UNPKG

1.23 kBTypeScriptView Raw
1import { Logger } from '@nestjs/common/services/logger.service';
2import { Client, NatsMsg } from '../external/nats-client.interface';
3import { NatsOptions, PacketId, ReadPacket, WritePacket } from '../interfaces';
4import { ClientProxy } from './client-proxy';
5/**
6 * @publicApi
7 */
8export declare class ClientNats extends ClientProxy {
9 protected readonly options: NatsOptions['options'];
10 protected readonly logger: Logger;
11 protected natsClient: Client;
12 constructor(options: NatsOptions['options']);
13 close(): Promise<void>;
14 connect(): Promise<any>;
15 createClient(): Promise<Client>;
16 handleStatusUpdates(client: Client): Promise<void>;
17 createSubscriptionHandler(packet: ReadPacket & PacketId, callback: (packet: WritePacket) => any): (error: unknown | undefined, natsMsg: NatsMsg) => Promise<any>;
18 protected publish(partialPacket: ReadPacket, callback: (packet: WritePacket) => any): () => void;
19 protected dispatchEvent(packet: ReadPacket): Promise<any>;
20 protected initializeSerializer(options: NatsOptions['options']): void;
21 protected initializeDeserializer(options: NatsOptions['options']): void;
22 protected mergeHeaders<THeaders = any>(requestHeaders?: THeaders): any;
23}