Options
All
  • Public
  • Public/Protected
  • All
Menu

Class TestClientProxy

Hierarchy

Index

Properties

Methods

Properties

Protected deserializer

deserializer: ProducerDeserializer

Protected routingMap

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

Protected serializer

serializer: ProducerSerializer

Methods

Protected assignPacketId

close

  • close(): Promise<void>

connect

  • connect(): Promise<void>

Protected connect$

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

Protected createObserver

  • createObserver<T>(observer: Observer<T>): (packet: WritePacket) => void

Protected dispatchEvent

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

emit

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

Protected getOptionsProp

  • getOptionsProp<T, K>(obj: T, prop: K, defaultValue?: T[K]): T[K]

Protected initializeDeserializer

  • initializeDeserializer(options: ClientOptions["options"]): void

Protected initializeSerializer

  • initializeSerializer(options: ClientOptions["options"]): void

Protected normalizePattern

  • normalizePattern(pattern: MsPattern): string

publish

  • publish(pattern: any, callback: any): any

send

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

Generated using TypeDoc