Properties
Protected routingMap
routing
Map: Map<string, Function> = new Map<string, Function>()Methods
Protected connect$
- connect$(instance: any, errorEvent?: string, connectEvent?: string): Observable<any>
-
Parameters
-
instance: any
-
Default value errorEvent: string = ERROR_EVENT
-
Default value connectEvent: string = CONNECT_EVENT
Returns Observable<any>
Protected createObserver
- createObserver<T>(observer: Observer<T>): (packet: WritePacket) => void
-
Type parameters
Parameters
Returns (packet: WritePacket) => void
Protected Abstract dispatchEvent
-
Type parameters
Parameters
Returns Promise<T>
emit
- emit<TResult, TInput>(pattern: any, data: TInput): Observable<TResult>
-
Type parameters
-
TResult = any
-
TInput = any
Parameters
-
pattern: any
-
data: TInput
Returns Observable<TResult>
Protected getOptionsProp
- getOptionsProp<T, K>(obj: T, prop: K, defaultValue?: T[K]): T[K]
-
Type parameters
-
T: ClientOptions["options"]
-
K: keyof T
Parameters
-
obj: T
-
prop: K
-
Default value defaultValue: T[K] = undefined
Returns T[K]
Protected initializeDeserializer
- initializeDeserializer(options: ClientOptions["options"]): void
-
Parameters
-
options: ClientOptions["options"]
Returns void
Protected initializeSerializer
- initializeSerializer(options: ClientOptions["options"]): void
-
Parameters
-
options: ClientOptions["options"]
Returns void
Protected normalizePattern
-
Parameters
Returns string
Protected Abstract publish
send
- send<TResult, TInput>(pattern: any, data: TInput): Observable<TResult>
-
Type parameters
-
TResult = any
-
TInput = any
Parameters
-
pattern: any
-
data: TInput
Returns Observable<TResult>