Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ClientGrpcProxy

Hierarchy

Implements

  • any

Index

Constructors

constructor

Properties

Protected grpcClient

grpcClient: any

Protected logger

logger: any = new Logger(ClientProxy.name)

Protected options

options: any

Protected routingMap

routingMap: any = new Map<string, Function>()

Protected url

url: string

Methods

Protected assignPacketId

close

  • close(): void

connect

  • connect(): Promise<any>

Protected connect$

  • connect$(instance: any, errorEvent?: string, connectEvent?: string): Observable<any>

createClient

  • createClient(): any

Protected createObserver

  • createObserver<T>(observer: Observer<T>): function

createServiceMethod

  • createServiceMethod(client: any, methodName: string): function
  • Parameters

    • client: any
    • methodName: string

    Returns function

      • (...args: any[]): Observable<any>
      • Parameters

        • Rest ...args: any[]

        Returns Observable<any>

createStreamServiceMethod

  • createStreamServiceMethod(client: any, methodName: string): function
  • Parameters

    • client: any
    • methodName: string

    Returns function

      • (...args: any[]): Observable<any>
      • Parameters

        • Rest ...args: any[]

        Returns Observable<any>

createUnaryServiceMethod

  • createUnaryServiceMethod(client: any, methodName: string): function
  • Parameters

    • client: any
    • methodName: string

    Returns function

      • (...args: any[]): Observable<any>
      • Parameters

        • Rest ...args: any[]

        Returns Observable<any>

Protected dispatchEvent

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

emit

  • emit<TResult, TInput>(pattern: any, data: TInput): Observable<TResult>

Protected getOptionsProp

  • getOptionsProp<T>(obj: any, prop: keyof T["options"], defaultValue?: any): any

getService

  • getService<T>(name: string): T

loadProto

  • loadProto(): any

lookupPackage

  • lookupPackage(root: any, packageName: string): any

Protected normalizePattern

  • normalizePattern<T>(pattern: T): string

Protected publish

  • publish(packet: any, callback: function): any

send

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

Generated using TypeDoc