class ClientGrpcProxy extends ClientProxy implements ClientGrpc {
  constructor(options: { url?: string; maxSendMessageLength?: number; maxReceiveMessageLength?: number; maxMetadataSize?: number; keepalive?: { keepaliveTimeMs?: number; keepaliveTimeoutMs?: number; keepalivePermitWithoutCalls?: number; http2MaxPingsWithoutData?: number; http2MinTimeBetweenPingsMs?: number; http2MinPingIntervalWithoutData...)
  protected logger: Logger
  protected clients: Map<string, any>
  protected url: string
  protected grpcClients: GrpcClient[]
  status: never
  protected options: Required<GrpcOptions>['options']
  getService<T extends object>(name: string): T
  getClientByServiceName<T = unknown>(name: string): T
  createClientByServiceName(name: string)
  getKeepaliveOptions()
  createServiceMethod(client: any, methodName: string): (...args: unknown[]) => Observable<unknown>
  createStreamServiceMethod(client: unknown, methodName: string): (...args: any[]) => Observable<any>
  createUnaryServiceMethod(client: any, methodName: string): (...args: any[]) => Observable<any>
  createClients(): any[]
  loadProto(): any
  lookupPackage(root: any, packageName: string)
  close()
  connect(): Promise<any>
  send<TResult = any, TInput = any>(pattern: any, data: TInput): Observable<TResult>
  protected getClient(name: string): any
  protected publish(packet: any, callback: (packet: any) => any): any
  protected dispatchEvent(packet: any): Promise<any>
  on<EventKey extends never = never, EventCallback = any>(event: EventKey, callback: EventCallback)
  unwrap<T>(): T

  // inherited from nest/packages/microservices/ClientProxy
  protected routingMap: Map<string, Function>
  protected serializer: ProducerSerializer
  protected deserializer: ProducerDeserializer
  protected _status$: ReplaySubject<Status>
  status: Observable<Status>
  abstract connect(): Promise<any>
  abstract close(): any
  on<EventKey extends keyof EventsMap = keyof EventsMap, EventCallback extends EventsMap[EventKey] = EventsMap[EventKey]>(event: EventKey, callback: EventCallback)
  abstract unwrap<T>(): T
  send<TResult = any, TInput = any>(pattern: any, data: TInput): Observable<TResult>
  emit<TResult = any, TInput = any>(pattern: any, data: TInput): Observable<TResult>
  protected abstract publish(packet: ReadPacket<any>, callback: (packet: WritePacket<any>) => void): () => void
  protected abstract dispatchEvent<T = any>(packet: ReadPacket<any>): Promise<T>
  protected createObserver<T>(observer: Observer<T>): (packet: WritePacket) => void
  protected serializeError(err: any): any
  protected serializeResponse(response: any): any
  protected assignPacketId(packet: ReadPacket<any>): ReadPacket & PacketId
  protected connect$(instance: any, errorEvent: string = 'error', connectEvent: string = 'connect'): Observable<any>
  protected getOptionsProp<Options extends ClientOptions['options'], Attribute extends keyof Options, DefaultValue extends Options[Attribute] = Options[Attribute]>(obj: Options, prop: Attribute, defaultValue: DefaultValue = undefined as DefaultValue)
  protected normalizePattern(pattern: MsPattern): string
  protected initializeSerializer(options: { url?: string; maxSendMessageLength?: number; maxReceiveMessageLength?: number; maxMetadataSize?: number; keepalive?: { keepaliveTimeMs?: number; keepaliveTimeoutMs?: number; keepalivePermitWithoutCalls?: number; http2MaxPingsWithoutData?: number; http2MinTimeBetweenPingsMs?: number; http2MinPingIntervalWithoutData...)
  protected initializeDeserializer(options: { url?: string; maxSendMessageLength?: number; maxReceiveMessageLength?: number; maxMetadataSize?: number; keepalive?: { keepaliveTimeMs?: number; keepaliveTimeoutMs?: number; keepalivePermitWithoutCalls?: number; http2MaxPingsWithoutData?: number; http2MinTimeBetweenPingsMs?: number; http2MinPingIntervalWithoutData...)
}

Constructor

constructor(options: { url?: string; maxSendMessageLength?: number; maxReceiveMessageLength?: number; maxMetadataSize?: number; keepalive?: { keepaliveTimeMs?: number; keepaliveTimeoutMs?: number; keepalivePermitWithoutCalls?: number; http2MaxPingsWithoutData?: number; http2MinTimeBetweenPingsMs?: number; http2MinPingIntervalWithoutData...)

getService<T extends object>(name: string): T

getClientByServiceName<T = unknown>(name: string): T

createClientByServiceName(name: string)

getKeepaliveOptions()

createServiceMethod(client: any, methodName: string): (...args: unknown[]) => Observable<unknown>

createStreamServiceMethod(client: unknown, methodName: string): (...args: any[]) => Observable<any>

createUnaryServiceMethod(client: any, methodName: string): (...args: any[]) => Observable<any>

createClients(): any[]

loadProto(): any

lookupPackage(root: any, packageName: string)

close()

connect(): Promise<any>

send<TResult = any, TInput = any>(pattern: any, data: TInput): Observable<TResult>

protected getClient(name: string): any

protected publish(packet: any, callback: (packet: any) => any): any

protected dispatchEvent(packet: any): Promise<any>

on<EventKey extends never = never, EventCallback = any>(event: EventKey, callback: EventCallback)

unwrap<T>(): T